The first is sent when a user joins a room, the second when\nthe user leaves it and the third when a user posts a message in a room.<\/p>\n\n\n\n
We are going to add a new service to our mesh called “Chat Room Bridge”<\/em>. Its role is to\nconnect to the foreign system, read lines in the said formats, parse them and\nfeed them to our system as native Before starting, we need to tackle a small architectural\nproblem. In the previous lessons we had one chat application used by one user.\nThis let us identifying the user by the application UUID, which we used as a\ntrick to easily route messages to the proper destinations. This trick will not\nwork here, because we are going to have one application, the bridge, that\nrepresents all the users across it.<\/p>\n\n\n\n The solution is to make a slight change in the hierarchy of\nour Data Object Tree. We will insert a new data object class, With this change, Here is the modified The class is now defined (line 48) as a child of There is no change in The new structure requires few modifications to the chat\napplication. Here is The When the user joins a room, we need to first create a Similarly, when the user leaves the room, we first remove\nthe We removed Some implementation data objects are also modified. Let\u2019s\nsee As mentioned above, we added the Also in And finally Here onEvent()<\/a> (line 20) is slightly changed to fetch\nthe room name from the great-grandparent of the object rather than from its\ngrandparent. We also check if the parent\u2019s As mentioned above we have moved We are done with all the necessary modifications to the chat\napplication. Let\u2019s build the Chat Room\nBridge<\/em>. Here is The goal of the bridge is to import foreign data, convert it\nto Spiderwiz native Data Objects and distribute them. So the application\nproduces (line 40) Similarly, the bridge exports native Data Objects to the\nforeign system, so it consumes (line 52) the same objects (plus ObjectCodes.RawImport<\/a> that will be explained\nlater and may be ignored now).<\/p>\n\n\n\n The method populateObjectFactory()<\/a> (line 65) registers The interesting work is done in the implementation classes.\nHere is This is where We then parse the line. Lines that are relevant to Export is done in exportObject()<\/a> (line 60). First we verify that we do not bounce an imported object by comparing the application UUID to the object\u2019s origin UUID. We then make sure that the export channel is The reason we override isUrgent()<\/a> to return To activate export we need to override onNew()<\/a> (line 87) and onRemoval()<\/a> (line 96). In both cases we call commit(“”)<\/a>, which is what activates export (and native distribution). We use the empty string parameter because if we used the non-parameterized commit()<\/a> then the object would be bounced to the current application, and that would trigger an endless (until heap memory is exploited) recursive call to The other implementation class is Here we do pretty much the same thing. In onEvent()<\/a> (line 25) we call commit(\u201c\u201d)<\/a> to activate export (avoiding recursive\ncommits). In importObject()<\/a> (line 40) we verify that the import channel is In exportObject()<\/a> (line 70) we verify that we do not\nbounce an imported object and that the export channel is The filterDestination()<\/a> method (line 96) is called\nduring the distribution process of the object that was imported by This completes our coding mission. And where is the actual\ncommunication with the foreign system? Nice guess! In the configuration file of\ncourse. Here it is:<\/p>\n\n\n\n You can see one new property \u2013 Note that this property includes the parameter One more thing for your attention \u2013 when you run the\napplication with this test scenario you will see that a new folder is created\nunder the configured log folder named We still owe you an explanation about the When talking about interfacing with an existing system, it\nhappens often that these are production systems that programmers have limited\naccess to. The \u201cbridge\u201d that we built in this lesson requires programming for\nevery specific Data Object that is imported from or exported to the foreign\nsystem. If the access to the import channels referred to by the bridge is\nrestricted to modules running on the same production system then the bridge\nmust be collocated on the same system, and then every change to it or the\naddition of more bridges requires the unwelcome programmer access.<\/p>\n\n\n\n What you would prefer to do in this case is to have a\none-time installation of a \u201ccatch all\u201d bridge. This is a Spiderwiz application\nthat produces the entire raw data as received from the foreign system\nencapsulated in In fact they do much more because they completely free the\ndevelopers from worrying about the location of the foreign system and whether\nit is accessed directly or through a bridge. In the example demonstrated in\nthis lesson we can have the To have the whole picture we will demonstrate the\nimplementation of the remote bridge. Here is As you see, this is a barebones The configuration file is:<\/p>\n\n\n\n and if we do import-export through this application then we\ncan omit the import definition of If you run the examples of this lesson you may discover that\nthey do not work as you might except. The problem is that our tests use local\nfiles for accessing \u201cforeign data\u201d, and the input file is opened and read\nduring application initialization. Most probably, when the file is read,\nhandshake procedures on other communication channels have not yet been\ncompleted and therefore the processed file data cannot be delivered to other\napplications.<\/p>\n\n\n\n We want to activate file processing only after all other communication channels are fully established. This is done easily with the \u201chot reconfiguration\u201d feature of SpiderAdmin<\/a>. Here is how it works:<\/p>\n\n\n\n Initially when we run Chat\nRoom Bridge<\/em> we comment out the definition of the import channel, like this:<\/p>\n\n\n\n We run all the services that constitute the chat system,\nassuring that My Hub<\/em> is connected to SpiderAdmin<\/em> as in Lesson 3<\/a>.\nWhen we surf to SpiderAdmin<\/a>\nand log into the service, we should see something like this:<\/p>\n\n\n\n Look for Chat Room\nBridge <\/em>In the Applications<\/strong> table\nand click it. You should see this:<\/p>\n\n\n\n You see a row of buttons under the page title. Click Update Configuration<\/strong> and you will see\nthis:<\/p>\n\n\n\n Remove the commenting minus sign in front of the Then click the \u2713<\/span> symbol at the top right of the pop-up window.<\/p>\n\n\n\n The Chat Room Bridge<\/em>\nconsole now shows<\/p>\n\n\n\n and the imported data from that file shows up in the console\nof the chat applications that have joined the relevant rooms.<\/p>\n\n\n\n Wait a little while until SpiderAdmin page refreshes or\nrefresh it manually and you will see that the \u201cbridge\u201d import channel appeared\nin the Import Channels<\/strong> table:<\/p>\n\n\n\nChatter<\/code>\nand ChatMessage<\/code> objects. On the other\nhand the service listens to our chat rooms, converts Chatter<\/code> and ChatMessage<\/code>\nobjects to text lines of the above formats and transmits them to the foreign\nsystem.<\/p>\n\n\n\nChatApp<\/code>, as a child of ChatRoom<\/code> and a parent of Chatter<\/code>. ChatApp<\/code> has no properties and is identified by the application\nUUID. Its children of type Chatter<\/code>\nare identified by the user name. As there can be multiple Chatter<\/code> children to a single ChatApp<\/code>\nobject, the problem is solved elegantly.<\/p>\n\n\n\nChatRoom<\/code>\nremains as it is. The new ChatApp<\/code>\nclass is just a barebones Data Object, defined as a non-disposable child of ChatRoom<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.objectLib;\n\nimport org.spiderwiz.core.DataObject;\n\n\/**\n * A DataObject class that represents a chat application within a specific chat room. It is the parent of all the chatters that\n * are in that application and joined the room that is the parent of this object.\n *\/\npublic class ChatApp extends DataObject {\n \/**\n * Mandatory public static field for all data objects.\n *\/\n public final static String ObjectCode = "CHTAPP";\n\n @Override\n protected String getParentCode() {\n return ChatRoom.ObjectCode;\n }\n\n @Override\n protected boolean isDisposable() {\n return false;\n }\n}<\/pre><\/div>\n\n\n\nChatter<\/code>\nclass:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.objectLib;\n\nimport org.spiderwiz.annotation.WizField;\nimport org.spiderwiz.core.DataObject;\nimport org.spiderwiz.zutils.ZDate;\n\n\/**\n * A data object that represents a chat user using a specific chat application in a specific chat room\n *\/\npublic class Chatter extends DataObject {\n \/**\n * Mandatory public static field for all data objects.\n *\/\n public final static String ObjectCode = "CHTTR";\n \n @WizField private String name; \/\/ Contains the name of the chatter\n @WizField private ZDate birthday; \/\/ Contains the chatter birth date\n @WizField private boolean stealth = false; \/\/ True if chatters shall not be notified when this user joins or leave a room\n\n public String getName() {\n return name;\n }\n\n public void setName(String name) {\n this.name = name;\n }\n\n public ZDate getBirthday() {\n return birthday;\n }\n\n public void setBirthday(ZDate birthday) {\n this.birthday = birthday;\n }\n\n public boolean isStealth() {\n return stealth;\n }\n\n public void setStealth(boolean stealth) {\n this.stealth = stealth;\n }\n\n \/**\n * @return ChatRoom object code\n *\/\n @Override\n protected String getParentCode() {\n return ChatApp.ObjectCode;\n }\n\n \/**\n * @return false because objects of this class are persistent\n *\/\n @Override\n protected boolean isDisposable() {\n return false;\n }\n\n \/**\n * The object ID, which is the user name, is case insensitive.\n * @return\n *\/\n @Override\n protected boolean isCaseSensitive() {\n return false;\n }\n}<\/pre><\/div>\n\n\n\nChatApp<\/code>. We also define it as case\ninsensitive (line 65) since the object ID is now the user name that we do not\nwant to bother with its case.<\/p>\n\n\n\nChatMessage<\/code>\nand other library classes.<\/p>\n\n\n\nChatMain<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.chat;\n\nimport java.io.PrintStream;\nimport java.text.ParseException;\nimport java.util.Collection;\nimport java.util.List;\nimport org.spiderwiz.core.DataObject;\nimport org.spiderwiz.tutorial.objectLib.ActiveUserQuery;\nimport org.spiderwiz.tutorial.objectLib.Chat;\nimport org.spiderwiz.tutorial.objectLib.ChatApp;\nimport org.spiderwiz.tutorial.objectLib.ChatHistoryQuery;\nimport org.spiderwiz.tutorial.objectLib.ChatMessage;\nimport org.spiderwiz.tutorial.objectLib.ChatRoom;\nimport org.spiderwiz.tutorial.objectLib.Chatter;\nimport org.spiderwiz.tutorial.objectLib.ConsoleMain;\nimport org.spiderwiz.tutorial.objectLib.LoginQuery;\nimport org.spiderwiz.zutils.ZDate;\nimport org.spiderwiz.zutils.ZUtilities;\n\n\/**\n * Provides the entry point of the application. Initializes and executes the Spiderwiz framework.\n *\/\npublic class ChatMain extends ConsoleMain{\n private static final String ROOT_DIRECTORY = "";\n private static final String APP_NAME = "Chat Room Client";\n private static final String APP_VERSION = "Z11.01"; \/\/ Version Z11.01: Lesson 11 modifications\n\n private static final String JOIN = "!join"; \/\/ join a chat room command\n private static final String LEAVE = "!leave"; \/\/ leave current chat room command\n private static final String LOGIN = "!login"; \/\/ start login procedure\n private static final String LOGOUT = "!logout"; \/\/ log the user out\n private static final String REGISTER = "!register"; \/\/ start registration procedure\n private static final String HISTORY = "!history"; \/\/ print my chat history\n \n private String myName = null; \/\/ The user login name\n private ZDate birthday = null; \/\/ User birth date. Get it when logging in\n private ChatterConsume chatter = null; \/\/ A Chatter object representing the user chatting in a specific room\n private ChatMessage message = null; \/\/ A ChatMessage object for committing chat messages\n private Chat privateMessage = null; \/\/ A Chat object for committing private messages\n\n \/**\n * Class constructor with constant parameters.\n * @param confFileName configuration file name, provided as a command argument\n *\/\n public ChatMain(String confFileName) {\n super(ROOT_DIRECTORY, confFileName, APP_NAME, APP_VERSION);\n }\n \n \/**\n * @return the class instance as ChatMain type.\n *\/\n public static ChatMain getInstance() {\n return (ChatMain)ConsoleMain.getInstance();\n }\n\n \/**\n * Application entry point. Instantiate the class and initialize the instance.\n * \n * @param args the command line arguments. The first argument is used as the configuration file name.\n *\/\n \/**\n * @param args the command line arguments\n *\/\n public static void main(String[] args) {\n \/\/ Don't do anything if there is no configuration file name\n if (args.length == 0) {\n System.out.println("Configuration file has not been defined");\n return;\n }\n new ChatMain(args[0]).init();\n }\n\n \/**\n * Print user instructions to the console.\n * @return true\n *\/\n @Override\n protected boolean preStart() {\n System.out.printf(\n "Welcome to the dynamic chat system.n"\n + "To log in type !login.n"\n + "To log out type !logout.n"\n + "To register type !register.n"\n + "To join a chat room or change your current chat room, type "!join <room name>".n"\n + "To leave your chat room, type "!leave".n"\n + "To send a message in the current chat room just type the message "\n + "(a message cannot start with either '>' or '!').n"\n + "To send a private message type '>' followed by name of the user you want to send "\n + "the private message to, followed by ':' for by the message.n"\n + "To print the history of your own messages, type "!history <hours>h" or "!history <days>d"n"\n + "(for instance "!history 3h" to see messages since 3 hours ago and "!history 1d" to see messages since 1 day"\n + " ago).n"\n + "or type just "!history" to see all your messages.n"\n + "To exit type 'exit'.n"\n );\n return true;\n }\n \n \/**\n * @return the list of produced objects - Chatter, Chat, ChatMessage and LoginQuery\n *\/\n @Override\n protected String[] getProducedObjects() {\n return new String[]{\n ChatApp.ObjectCode,\n Chatter.ObjectCode,\n Chat.ObjectCode,\n ChatMessage.ObjectCode,\n LoginQuery.ObjectCode,\n ChatHistoryQuery.ObjectCode\n };\n }\n\n \/**\n * @return the list of consumed objects - ChatRoom, Chatter, Chat, ChatMessage and ActiveUserQuery\n *\/\n @Override\n protected String[] getConsumedObjects() {\n return new String[]{\n ChatRoom.ObjectCode,\n ChatApp.ObjectCode,\n Chatter.ObjectCode,\n Chat.ObjectCode,\n ChatMessage.ObjectCode,\n ActiveUserQuery.ObjectCode\n };\n }\n\n \/**\n * Add implementation classes to the object factory list of this application.\n * @param factoryList\n *\/\n @Override\n protected void populateObjectFactory(List<Class<? extends DataObject>> factoryList) {\n super.populateObjectFactory(factoryList);\n factoryList.add(ChatRoomConsume.class);\n factoryList.add(ChatApp.class);\n factoryList.add(ChatterConsume.class);\n factoryList.add(ChatConsume.class);\n factoryList.add(ChatMessageImp.class);\n factoryList.add(LoginQuery.class);\n factoryList.add(ActiveUserQueryReply.class);\n factoryList.add(ChatHistoryQueryInquire.class);\n }\n\n \n \/**\n * Process an input line\n * @param line the line to be broadcast as a chat message.\n * @return true if processed successfully\n *\/\n @Override\n protected boolean processConsoleLine(String line) {\n try {\n \/\/ If the line starts with '!' this is a command line\n if (line.startsWith("!")) {\n String command[] = line.trim().split("s+", 2);\n switch (command[0].toLowerCase()) {\n case JOIN:\n \/\/ if room name is provided join the room\n if (command.length > 1)\n joinRoom(command[1]);\n break;\n case LEAVE:\n \/\/ If the user is in a room, leave it\n leaveRoom(null);\n break;\n case LOGIN:\n login();\n break;\n case LOGOUT:\n logout();\n break;\n case REGISTER:\n register();\n break;\n case HISTORY:\n if (myName == null)\n System.out.println("You must log in before requesting history.");\n else if (!getHistory(command.length < 2 ? null : command[1]))\n System.out.println("Invalid command argument");\n break;\n }\n return true;\n }\n \n \/\/ If the line starts with '>' split the line on the colon (':') and send the test\n \/\/ after the colon as a private message to the user with the name before the colon.\n if (line.startsWith(">")) {\n String cmd[] = line.substring(1).split(":");\n if (cmd.length < 2)\n return true;\n String destination = findUser(cmd[0]);\n if (destination == null)\n return true;\n \/\/ If didn't do yet, create an orphan Chatter object for sending private messages,\n \/\/ then prepare a ChatMessage object for sending private messages\n if (privateMessage == null) {\n privateMessage = createTopLevelObject(Chat.class, null);\n privateMessage.setName(myName);\n }\n \/\/ Set message and commit to destination\n privateMessage.setMessage(cmd[1]);\n privateMessage.setTime(ZDate.now());\n privateMessage.commit(destination);\n return true;\n }\n \n \/\/ If this is a normal message, make sure the user is in a room and broadcast the message\n if (message != null) {\n message.setMessage(line);\n message.setTime(ZDate.now());\n message.commit();\n }\n return true;\n } catch (NoSuchFieldException | IllegalAccessException ex) {\n \/\/ Theoretically arriving here if a data object does not contain ObjectCode static field or the field is not public.\n \/\/ In this case, send a command exception message.\n sendExceptionMail(ex, "Cannot instantiate a data object class", null, false);\n return false;\n }\n }\n public String getMyName() {\n return myName;\n }\n\n public ZDate getBirthday() {\n return birthday;\n }\n \n \/**\n * Get user name and password and log in.\n * @return a PrintStream object. Not needed by the caller but we use it as a trick to save coding.\n * @throws NoSuchFieldException If LoginQuery does not define ObjectCode static field.\n * @throws IllegalAccessException If LoginQuery.ObjectCode is not public.\n *\/\n private PrintStream login() throws NoSuchFieldException, IllegalAccessException {\n String username;\n String password;\n\n \/\/ Check if already logged in\n if (myName != null)\n return System.out.printf("You are already logged in as %s. To log in with another name log out first.n", myName);\n \n \/\/ Create a login query\n LoginQuery query = createQuery(LoginQuery.class);\n while(true) {\n \/\/ Get user name\n System.out.printf("(type Enter to exit login)n");\n username = readConsoleLine("User name:");\n if (username.isBlank())\n return exitLogin();\n do {\n \/\/ Get password\n password = readConsoleLine("Password:");\n if (password.isBlank())\n return exitLogin();\n\n \/\/ Post the login query\n query.setNewUser(false);\n query.setName(username);\n query.setPassword(password);\n query.post(5 * ZDate.SECOND);\n \n \/\/ If the query did not expire check login results, if it did, repeat.\n if (query.waitForReply()) {\n switch (query.getResult()) {\n case OK:\n myName = query.getName();\n birthday = query.getBirthday();\n return System.out.printf("Logged in successfully as %s.n", myName);\n case NOT_EXISTS:\n System.out.printf("User %s does not exist. Please try again.n", username);\n break;\n case WRONG_PASSWORD:\n System.out.printf("Password did not match, please try again.n");\n break;\n }\n } else\n return unavailableUserManager();\n } while (query.getResult() == LoginQuery.ResultCode.WRONG_PASSWORD);\n }\n }\n \n \/**\n * Log out if already logged in\n *\/\n private void logout() {\n if (myName == null) {\n System.out.printf("No user is logged in.n");\n return;\n }\n leaveRoom(null);\n System.out.printf("%s is logged out.n", myName);\n myName = null;\n birthday = null;\n }\n\n private PrintStream register() throws NoSuchFieldException, IllegalAccessException {\n String username;\n String password, password2;\n\n \/\/ Check if already logged in\n if (myName != null)\n return System.out.printf("You are already logged in as %s. To register a new user log out first.n", myName);\n \n \/\/ Create a registration query\n LoginQuery query = createQuery(LoginQuery.class);\n while(true) {\n \/\/ Get user name\n System.out.printf("(type Enter to exit login)n");\n username = readConsoleLine("User name:");\n if (username.isBlank())\n return exitRegistration();\n do {\n \/\/ Get password\n password = readConsoleLine("Password:");\n if (password.isBlank())\n return exitRegistration();\n\n \/\/ Repeat the password\n password2 = readConsoleLine("Repeat password:");\n if (password2.isBlank())\n return exitRegistration();\n \n \/\/ Check if passwords are equal\n if (password.equals(password2))\n break;\n System.out.println("Passwords do not match.");\n } while (true);\n \n \/\/ Get and parse birth date\n do {\n String s = readConsoleLine("Date of birth (yyyy\/mm\/dd):");\n if (s.isBlank())\n return exitRegistration();\n try {\n birthday = ZDate.parseTime(s, "yyyy\/MM\/dd", null);\n } catch (ParseException ex) {\n birthday = null;\n System.out.printf("Invalid date %s. Please try again.n", s);\n }\n } while (birthday == null);\n\n \/\/ Post the registration query\n query.setNewUser(true);\n query.setName(username);\n query.setPassword(password);\n query.setBirthday(birthday);\n query.post(5 * ZDate.SECOND);\n\n \/\/ If the query did not expire check login results, if it did, repeat.\n if (query.waitForReply()) {\n switch (query.getResult()) {\n case OK:\n myName = username;\n return System.out.printf("Registered and logged in successfully as %s.n", myName);\n case EXISTS:\n System.out.printf("User %s already exista. Please try again with another name.n", username);\n break;\n }\n } else\n return unavailableUserManager();\n }\n }\n \n \/**\n * Print a message when login existed by typing a blank Enter\n * @return a PrintStream object. Not needed by the caller but we use it as a trick to save coding.\n *\/\n private PrintStream exitLogin() {\n return System.out.printf("Login exitedn");\n }\n \n \/**\n * Print a message when registration existed by typing a blank Enter\n * @return a PrintStream object. Not needed by the caller but we use it as a trick to save coding.\n *\/\n private PrintStream exitRegistration() {\n return System.out.printf("Registration exitedn");\n }\n \n \/**\n * Print a message when user management is not available\n * @return a PrintStream object. Not needed by the caller but we use it as a trick to save coding.\n *\/\n private PrintStream unavailableUserManager() {\n return System.out.printf("No user management entity is available to handle this requestn");\n }\n \n \/**\n * Join a room after checking that the room exists, its adult setting matches user configuration,\n * and the user is not already there. If the user is in another room leave that room first.\n * @param room the new room name\n * @throws NoSuchFieldException If any of the created data objects does not define ObjectCode static field.\n * @throws IllegalAccessException If ObjectCode is not public.\n *\/\n private synchronized void joinRoom(String room) throws NoSuchFieldException, IllegalAccessException {\n \/\/ User must be logged in\n if (myName == null) {\n System.out.printf("You must log in before joining a room.n");\n return;\n }\n \n \/\/ Check whether room exists and the user is not already in the room\n ChatRoomConsume chatRoom = getRootObject().getChild(ChatRoomConsume.class, room);\n if (chatRoom == null) {\n System.out.printf("Room %s does not existn", room);\n return;\n }\n\n if (chatter != null && room.equalsIgnoreCase(chatter.getRoomName()))\n return;\n \n \/\/ Check if a young chatters is trying to join an adult room\n if (!chatRoom.canJoin(birthday)) {\n System.out.printf("You cannot join room %s because it is only for adultsn", room);\n return;\n }\n \n \/\/ Leave current room if any\n leaveRoom(null);\n \n \/\/ Join the application to the room\n ChatApp chatApp = chatRoom.createChild(ChatApp.class, getAppUUID().toString());\n \n \/\/ Create a Chatter object for the user that joins the specified room\n chatter = chatApp.createChild(ChatterConsume.class, myName);\n chatter.setName(myName);\n chatter.setBirthday(birthday);\n chatter.commit(); \/\/ let everybody know I joined the room\n \/\/ Prepare a ChatMessage object for sending messages from now on\n message = chatter.createChild(ChatMessage.class, null);\n System.out.printf("Joined room %sn", room);\n }\n \n \/**\n * If the user is in the given room, leave it.\n * @param room the name of the room to be checked if the user is there. If null, leave the current room without checking\n *\/\n public synchronized void leaveRoom(String room) {\n if (isSameRoom(room)) {\n \/\/ Leave the room and let everybody know I did\n DataObject removed = chatter.remove();\n if (removed != null) \/\/ can be null if the 'chatter' object has already been removed.\n removed.commit();\n \n \/\/ Disconnect the application from the room and let every application know it did\n removed = chatter.getParent().remove();\n if (removed != null)\n removed.commit();\n System.out.printf("Left room %sn", chatter.getRoomName());\n chatter = null;\n message = null;\n }\n }\n \n \/**\n * Check if the user is in the same room as the parameter\n * @param room the name of the room to be checked if the user is there. If null, return true\n * @return true if the user in 'room' or 'room' is null\n *\/\n public synchronized boolean isSameRoom(String room) {\n return chatter != null &&\n (room == null || room.equalsIgnoreCase(chatter.getRoomName()));\n }\n \n \/**\n * Get current room name, if any\n * @return if the user is currently in a room return the room name, otherwise return null.\n *\/\n public synchronized String getCurrentRoom() {\n return chatter == null ? null : chatter.getRoomName();\n }\n \n \/**\n * Find the user whose name equals the parameter\n * @param name user name to look for\n * @return If a Chatter object for this user found then return the object ID of its grandparent, which is the UUID of the\n * application that the given user runs, otherwise return null.\n * @throws NoSuchFieldException If any of the referred data objects does not define ObjectCode static field.\n * @throws IllegalAccessException If ObjectCode is not public.\n *\/\n private String findUser(String name) throws NoSuchFieldException, IllegalAccessException {\n FindUserFilter filter = new FindUserFilter(name);\n Collection<Chatter> users = getRootObject().getFilteredChildren(filter);\n \/\/ If the returned collection is not empty return the object ID (which is a UUID) of the first,\n \/\/ otherwise return null.\n for (Chatter user : users) {\n return user.getParent().getObjectID();\n }\n return null;\n }\n \n \/**\n * Execute !history command\n * @param arg command argument - <n>H or <n>D\n * @return true if command has been parsed successfully.\n * @throws NoSuchFieldException If ChatHistoryQuery does not define ObjectCode static field.\n * @throws IllegalAccessException If ChatHistoryQuery.ObjectCode is not public.\n *\/\n private boolean getHistory(String arg) throws NoSuchFieldException, IllegalAccessException {\n \/\/ Parse the argument and calculate time\n ZDate since = null;\n if (arg != null) {\n arg = arg.trim().toLowerCase();\n int n = ZUtilities.parseInt(arg.substring(0, arg.length() - 1));\n if (n <= 0)\n return false;\n int unit;\n switch (arg.substring(arg.length() - 1)) {\n case "h":\n unit = ZDate.HOUR;\n break;\n case "d":\n unit = ZDate.DAY;\n break;\n default:\n return false;\n }\n since = ZDate.now().add(-n * unit);\n }\n \n \/\/ create a query and post it\n ChatHistoryQuery query = createQuery(ChatHistoryQuery.class);\n query.setUsername(myName);\n query.setSince(since);\n query.post(5 * ZDate.SECOND);\n return true;\n }\n}<\/pre><\/div>\n\n\n\nchatter<\/code> field\nis now defined as ChatterConsume<\/code>\n(line 37). We will see in a second why.<\/p>\n\n\n\nChatApp<\/code> is added\nto the produced object list (line 105). This is needed for the routing\nprocedure of peer applications. For this reason it is also added to the\nconsumed object list (line 121). The class is also registered in populateObjectFactory()<\/a> (line 137).<\/p>\n\n\n\nChatRoom<\/code> is now\nthe grandparent of Chatter<\/code> rather\nthan its immediate parent and we have to consider this change when we extract\nthe room name from a Chatter<\/code> object.\nFor that purpose we added the getRoomName()<\/code>\nmethod to ChatterConsume<\/code>. You can see\nits use in lines 412, 465 and 473. Also in findUser()<\/code>\n(line 484), which is supposed to return an application UUID, we now return the\nobject ID of the parent of the found Chatter<\/code>\nobject rather than its own ID.<\/p>\n\n\n\nChatApp<\/code> object under the desired ChatRoom<\/code> object and then create a Chatter<\/code> object under it. This is done in\nlines 424 \u2013 428.<\/p>\n\n\n\nChatter<\/code> object and commit the\naction so that peer users are notified, then remove the ChatApp<\/code> object and commit it so that peer applications know not to\nroute room messages to this application. This is done in lines 443 \u2013 452.<\/p>\n\n\n\nisMemberOfMyRoom()<\/code>\nall together because we now do it in ChatMessageImp<\/code>\nas we will see in a moment.<\/p>\n\n\n\nChatterConsume<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.chat;\n\nimport org.spiderwiz.tutorial.objectLib.Chatter;\n\n\/**\n * Consumer implementation of Chatter data object. Notify when a chatter enters or leaves my room.\n *\/\npublic class ChatterConsume extends Chatter {\n\n \/**\n * Notify when a chatter enters my room.\n *\/\n @Override\n protected void onNew() {\n if (!isStealth() && ChatMain.getInstance().isSameRoom(getRoomName()) && getName() != null)\n System.out.printf("%s entered the roomn", getName());\n }\n\n \/**\n * Notify when a chatter leaves my room. If the chatter is myself leave the room gracefully.\n * @return true to confirm the removal.\n *\/\n @Override\n protected boolean onRemoval() {\n if (ChatMain.getInstance().getAppUUID().toString().equals(getParent().getObjectID()))\n ChatMain.getInstance().leaveRoom(getRoomName());\n else if (!isStealth() && ChatMain.getInstance().isSameRoom(getRoomName()) && getName() != null)\n System.out.printf("%s left the roomn", getName());\n return true;\n }\n \n \/**\n * Utility function to get the room name, which is the ID of the grand parent of the current object.\n * @return the room name\n *\/\n String getRoomName() {\n return getParent().getParent().getObjectID();\n }\n}<\/pre><\/div>\n\n\n\ngetRoomName()<\/code> method (line 34) that returns the object ID of the grandparent<\/strong> of this object. This is used in onNew()<\/a> (line 15) and onRemoval()<\/a> (line 24).<\/p>\n\n\n\nonRemoval()<\/code>\nwe compare the application UUID against the object ID of the parent of this\nobject rather than its own ID.<\/p>\n\n\n\nChatMessageImp<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.chat;\n\nimport java.util.Map;\nimport java.util.UUID;\nimport org.spiderwiz.tutorial.objectLib.ChatApp;\nimport org.spiderwiz.tutorial.objectLib.ChatMessage;\nimport org.spiderwiz.tutorial.objectLib.ChatRoom;\nimport org.spiderwiz.tutorial.objectLib.Chatter;\n\n\/**\n * Consumer implementation of the ChatMessage class\n *\/\npublic class ChatMessageImp extends ChatMessage {\n \/**\n * Called when a chat message is received. Check if the message has been sent in the room we are in,\n * then print the sender name and the message.\n * @return true to indicate that the event has been handled.\n *\/\n @Override\n protected boolean onEvent() {\n if (ChatMain.getInstance().isSameRoom(getParent().getParent().getParent().getObjectID())) {\n String name = ((Chatter)getParent()).getName();\n if (name == null)\n name = getParent().getObjectID();\n System.out.printf("%1$s: %2$sn", name, getMessage());\n }\n return true;\n }\n\n \/**\n * Restrict message sending to:\n * 1. applications that are not the current application.\n * 2. applications that are on the same chat room as the current user.\n * @param appUUID destination application UUID\n * @param appName destination application name\n * @param userID destination user ID\n * @param remoteAddress remote network address\n * @param appParams application parameters of the destination application\n * @return true if the object should be sent to this destination\n *\/\n @Override\n protected boolean filterDestination(UUID appUUID, String appName, String userID, String remoteAddress,\n Map<String, String> appParams\n ) {\n return\n !ChatMain.getInstance().getAppUUID().equals(appUUID) && isMemberOfMyRoom(appUUID);\n }\n\n \/**\n * Check if the user running the application whose UUID is given is on the same room as this message is sent to.\n * @param appUUID Application UUID to check\n * @return true if the application is in the same room as us.\n *\/\n private boolean isMemberOfMyRoom(UUID appUUID) {\n try {\n \/\/ The room is the great-grandparent of the message\n ChatRoom chatRoom = (ChatRoom)getParent().getParent().getParent();\n return chatRoom.getChild(ChatApp.class, appUUID.toString()) != null;\n } catch (NoSuchFieldException | IllegalAccessException ex) {\n \/\/ Arriving here if a ChatApp does not contain ObjectCode static field or the field is not public.\n \/\/ In this case, send a command exception message.\n ChatMain.getInstance().sendExceptionMail(ex, "Cannot instantiate ChatApp", null, false);\n return false;\n }\n }\n \n}<\/pre><\/div>\n\n\n\nname<\/code>\nproperty is null<\/code> before printing the\nmessage, because when data is imported from the foreign system we cannot trust\nthat we get a Chatter<\/code> object before\nreceiving this ChatMessage<\/code> object. If\nit is null<\/code>, we take the user name\nfrom the object ID of the parent (this is always available since, when\nreceiving a ChatMessage<\/code> object whose\nparent is not recognized, the framework creates an empty Chatter<\/code> object and uses it as the parent of the received object).\nNote that if the name<\/code> property is not\nnull<\/code> then we use it rather than the\nobject ID because the latter is case insensitive while we prefer to display a\ncase sensitive name.<\/p>\n\n\n\nisMemberOfMyRoom()<\/code> from ChatMain<\/code>\nto this class (line 54). The method is used in filterDestination()<\/a> (line 42). The method checks\nif the great-grandparent of the current object, which is a ChatRoom<\/code> object, has a child whose object ID equals the appUUID<\/code> parameter. Recall that ChatRoom<\/code> children are all the ChatApp<\/code> objects that are in the room.<\/p>\n\n\n\nBridgeMain<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.bridge;\n\nimport java.util.List;\nimport org.spiderwiz.core.DataObject;\nimport org.spiderwiz.tutorial.objectLib.ChatApp;\nimport org.spiderwiz.tutorial.objectLib.ChatMessage;\nimport org.spiderwiz.tutorial.objectLib.ChatRoom;\nimport org.spiderwiz.tutorial.objectLib.Chatter;\nimport org.spiderwiz.tutorial.objectLib.ConsoleMain;\n\n\/**\n * Provides the entry point of the application. Initializes and executes the Spiderwiz framework.\n *\/\npublic class BridgeMain extends ConsoleMain {\n private static final String ROOT_DIRECTORY = "";\n private static final String CONF_FILENAME = "bridge.conf";\n private static final String APP_NAME = "Chat Room Bridge";\n private static final String APP_VERSION = "Z1.01"; \/\/ Version Z1.01: Initial version\n\n \/**\n * Class constructor with constant parameters. Call super constructor and create the user map.\n *\/\n public BridgeMain() {\n super(ROOT_DIRECTORY, CONF_FILENAME, APP_NAME, APP_VERSION);\n }\n \n \/**\n * Application entry point. Instantiate the class and initialize the instance.\n * \n * @param args the command line arguments. Not used in this application.\n *\/\n public static void main(String[] args) {\n new BridgeMain().init();\n }\n\n \/**\n * @return the list of produced objects\n *\/\n @Override\n protected String[] getProducedObjects() {\n return new String[]{\n Chatter.ObjectCode,\n ChatMessage.ObjectCode,\n ObjectCodes.RawExport \/\/ predefined code for exporting raw data to a remote service\n };\n }\n\n \/**\n * @return the list of consumed objects\n *\/\n @Override\n protected String[] getConsumedObjects() {\n return new String[]{\n Chatter.ObjectCode,\n ChatMessage.ObjectCode,\n ObjectCodes.RawImport \/\/ predefined code for importing raw data from a remote service\n };\n }\n\n \/**\n * Add implementation classes to the object factory list of this application.\n * @param factoryList\n *\/\n @Override\n protected void populateObjectFactory(List<Class<? extends DataObject>> factoryList) {\n super.populateObjectFactory(factoryList);\n factoryList.add(ChatRoom.class);\n factoryList.add(ChatApp.class);\n factoryList.add(ChatterBridge.class);\n factoryList.add(ChatMessageBridge.class);\n }\n\n \/**\n * Process an input line - nothing to process in our case.\n * @param line The input line\n * @return true\n *\/\n @Override\n protected boolean processConsoleLine(String line) {\n return true;\n }\n}<\/pre><\/div>\n\n\n\nChatter<\/code> and ChatMessage<\/code> objects. (You can see that\nit also produces ObjectCodes.RawExport<\/a>. We will show its use later\nbut for now you can safely ignore it).<\/p>\n\n\n\nChatRoom<\/code>, ChatApp<\/code> and the implementation classes ChatterBridge<\/code> and ChatMessageBridge<\/code>. Nothing to do in processConsoleLine()<\/code> (line 79).<\/p>\n\n\n\nChatterBridge<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.bridge;\n\nimport org.spiderwiz.core.ImportHandler;\nimport org.spiderwiz.tutorial.objectLib.Chatter;\nimport org.spiderwiz.zutils.ZDate;\nimport org.spiderwiz.zutils.ZUtilities;\n\n\/**\n * Extend Chatter to implement import\/export from\/to an external chat system.\n * Data from the external system is received as text lines, each in the form of:\n * <room name>,<chatter name>,<message>\n * The line can report that a user joined a room with:\n * !join,<room name>,<chatter name>\n * When a user leaves a room the following line reports it:\n * !leave,<room name><chatter name>\n *\/\npublic class ChatterBridge extends Chatter {\n\n \/**\n * Parse import lines and handle them if they are either !join or !leave command\n * @param data the imported data line.\n * @param channel the handler of the channel the data is imported from. Shall be "bridge".\n * @param ts the timestamp attached to the data by the channel handler.\n * @return the key hierarchy of the imported object - room name then application UUID then user name, or null\n * if this is not a !join command\n * @throws Exception\n *\/\n @Override\n protected String[] importObject(Object data, ImportHandler channel, ZDate ts) throws Exception {\n \/\/ check if the import handler name is "bridge"\n if (!"bridge".equalsIgnoreCase(channel.getName()))\n return null;\n \n \/\/ parse the line\n String elements[] = data.toString().split(",", 3);\n if (elements.length < 3)\n return null;\n switch(elements[0]) {\n case "!leave":\n \/\/ Import the removal then proceed as if joined.\n if (remove() == null)\n return null;\n case "!join":\n \/\/ Set user name and return the key list of the joining (or leaving) user\n setName(elements[2]);\n return new String[] {elements[1], getMyUUID(), getName()};\n }\n \n \/\/ In all other cases return null\n return null;\n }\n\n \/**\n * Export a !join or !leave command\n * @param channel the handler of the channel the object will be exported to. Shall be "bridge".\n * @param newID null if this object is active, empty string if it has been removed, non-empty string if it has been renamed.\n * @return the serialized object to export\n *\/\n @Override\n protected String exportObject(ImportHandler channel, String newID) {\n \/\/ Do not export my own object\n if (BridgeMain.getInstance().getAppUUID().equals(getOriginUUID()))\n return null;\n \n \/\/ check if the import handler name is "bridge"\n if (!"bridge".equalsIgnoreCase(channel.getName()))\n return null;\n \n \/\/ determine if we need to export a "!join" or a "!leave" command, then generate the command\n String command = newID == null ? "!join" : "!leave";\n return ZUtilities.concatAll(",", command, getRoomName(), getName());\n }\n\n \/**\n * @return true to make Chatter as urgent as ChatMessage, otherwise object imported from a sequential file might be delivered\n * in the wrong order.\n *\/\n @Override\n protected boolean isUrgent() {\n return true;\n }\n\n \/**\n * When a new chatter in a room is encountered, export it\n *\/\n @Override\n protected void onNew() {\n commit("");\n }\n\n \/**\n * When a chatter leaves a room, export the command\n * @return true to confirm the removal.\n *\/\n @Override\n protected boolean onRemoval() {\n \/\/ Done exactly as oneNew(). exportObject() detects whether this is a join or a leave case.\n commit("");\n return true;\n }\n \n \/**\n * @return the current application UUID as a string\n *\/\n private String getMyUUID() {\n return BridgeMain.getInstance().getAppUUID().toString();\n }\n \n \/**\n * Utility function to get the room name, which is the ID of the grand parent of the current object.\n * @return the room name\n *\/\n String getRoomName() {\n return getParent().getParent().getObjectID();\n }\n}<\/pre><\/div>\n\n\n\nChatter<\/code> objects are imported and exported. Import is done in importObject()<\/a> (line 29). Its parameters are the imported raw data<\/code>, the channel<\/code> through which the data is received and a time stamp. We first check if the channel name is \"bridge\"<\/code>. This is necessary because in theory data can be imported from multiple sources in various formats, and in order to interpret it we need to identify the source.<\/p>\n\n\n\nChatter<\/code> objects start with either \"!join\"<\/code> or \"!leave\"<\/code>. The first is received when a chatter joins a room. In both cases we set the name<\/code> property of the current object and return a string array that contains the object key list starting from the root \u2013 room name that identifies the grandparent ChatRoom<\/code> object, the current application UUID that identifies the parent ChatApp<\/code> object and the user name that identifies the current object. The difference is that In the \u201c!leave\u201d<\/code> case we first call remove()<\/a> on the object to mark it for deletion. That\u2019s it!<\/p>\n\n\n\n\"bridge\"<\/code>. Finally we construct either a \"!join\"<\/code> or \"!leave\"<\/code> command depending on the value of the newID<\/code> parameter. We return the constructed string and we are done.<\/p>\n\n\n\ntrue<\/code> (line 79) is that, if you still remember, ChatMassage.isUrgent()<\/code> returns true<\/code>, and if both classes do not return the same value then we cannot guarantee the order by which the imported objects are distributed.<\/p>\n\n\n\nonNew()<\/code> or onRemoval()<\/code>. The empty string means \u201cdo not send it to any consumer but still export it\u201d.<\/p>\n\n\n\nChatMessageBridge<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.bridge;\n\nimport java.util.Map;\nimport java.util.UUID;\nimport org.spiderwiz.core.ImportHandler;\nimport org.spiderwiz.tutorial.objectLib.ChatApp;\nimport org.spiderwiz.tutorial.objectLib.ChatMessage;\nimport org.spiderwiz.tutorial.objectLib.ChatRoom;\nimport org.spiderwiz.tutorial.objectLib.Chatter;\nimport org.spiderwiz.zutils.ZDate;\nimport org.spiderwiz.zutils.ZUtilities;\n\n\/**\n * Implementation class of ChatMessagee for Chat Room Bridge.\n * Data from and to the external system is delivered as text lines, each in the form of:\n * <room name>,<chatter name>,<message>\n*\/\npublic class ChatMessageBridge extends ChatMessage {\n\n \/**\n * If this is not a bounced message that was imported by this application then commit it to itself in order to export it.\n * @return true;\n *\/\n @Override\n protected boolean onEvent() {\n commit("");\n return true;\n }\n\n \/**\n * Parse import lines of the form <room name>,<chatter name>,<message> and use the elements to feed\n * ChatMessage objects to the system.\n * @param data the imported data string.\n * @param channel the handler of the channel the data is imported from.\n * @param ts the timestamp attached to the data by the channel handler.\n * @return the key hierarchy of the imported object - room name then application UUID\n * @throws Exception\n *\/\n @Override\n protected String[] importObject(Object data, ImportHandler channel, ZDate ts) throws Exception {\n \/\/ check if the import handler name is "bridge"\n if (!"bridge".equalsIgnoreCase(channel.getName()))\n return null;\n \n \/\/ Parse the line and process it\n String elements[] = data.toString().split(",", 3);\n if (elements.length < 3)\n return null;\n switch(elements[0]) {\n case "!join":\n case "!leave":\n return null;\n }\n \n setMessage(elements[2]);\n setTime(ts);\n \/\/ Return the key sequence\n return new String[] {elements[0], BridgeMain.getInstance().getAppUUID().toString(), elements[1]};\n }\n\n \/**\n * Serialize the object for exporting.\n * @param channel the handler of the channel the object will be exported to.\n * @param newID null if this object is active, empty string if it has been removed, non-empty string if it has been renamed.\n * In this case it is always null because ChatMessage is disposable.\n * @return the serialized object to export in the form <room name>,<chatter name>,<message>.\n * If the object is imported we don't want to bounce it so we return null;\n *\/\n @Override\n protected String exportObject(ImportHandler channel, String newID) {\n \/\/ Don't bounce imported objects\n if (BridgeMain.getInstance().getAppUUID().equals(getOriginUUID()))\n return null;\n \n \/\/ check if the import handler name is "bridge"\n if (!"bridge".equalsIgnoreCase(channel.getName()))\n return null;\n\n \/\/ serialize\n String room = getParent().getParent().getParent().getObjectID();\n String chatter = ((Chatter)getParent()).getName();\n return ZUtilities.concatAll(",", room, chatter, getMessage());\n }\n\n \/**\n * Make sure the object is delivered to the right destinations, i.e. to chatters in the same room or to other bridge applications.\n * @param appUUID Application UUID of the destination\n * @param appName Application name of the destination. Not relevant here.\n * @param userID User ID used for establishing communication. N\/A.\n * @param remoteAddress Remote address of the destination application. N\/A.\n * @param appParams application parameter map of the destination. If it includes "role" -> "bridge" mapping\n * then deliver all messages with no further filtering.\n * @return true to approve distribution to this application, false to deny it.\n *\/\n @Override\n protected boolean filterDestination(UUID appUUID, String appName, String userID,\n String remoteAddress, Map<String, String> appParams)\n {\n try {\n \/\/ Check if the destination is for the same room\n ChatRoom chatRoom = (ChatRoom)getParent().getParent().getParent();\n return chatRoom.getChild(ChatApp.class, appUUID.toString()) != null;\n } catch (NoSuchFieldException | IllegalAccessException ex) {\n \/\/ Arriving here if ChatApp does not contain ObjectCode static field or the field is not public.\n \/\/ In this case, send an exception message.\n BridgeMain.getInstance().sendExceptionMail(ex, "Cannot instantiate ChatApp class", null, false);\n return false;\n }\n }\n}<\/pre><\/div>\n\n\n\n\u201cbridge\u201d<\/code>, parse the imported data (that is supposed to be a text\nstring), and if it is a chat message we store the values in the current object\nand return its hierarchy key as a string array \u2013 [room name, current\napplication UUID, user name]. <\/p>\n\n\n\n\u201cbridge\u201d<\/code>, then we construct the export message from the object\nproperties and return it.<\/p>\n\n\n\nimportObject()<\/code>. We override it to\nrestrict object routing to applications whose users are in the same room as the\nobject, just like the chat applications do.<\/p>\n\n\n\n[log folder]\/tests\/Bridge\/Logs\n[producer-1]ip=localhost;port=10001\n[import-1]infile=\/tests\/Remote\/ImportIn.txt;outfile=\/tests\/Remote\/ImportOut.txt;name=bridge<\/pre><\/div>\n\n\n\n
import-1<\/code>. In this case we use text files for input and output, but\nyou can also use other configurations.<\/a> You can also write\nyour own import handler plugin<\/a> to extend the default one or to\nsupport other types of foreign data.<\/p>\n\n\n\nname=bridge<\/code>. This gives the input\nchannel the \u201cbridge\u201d<\/code> name that is\nchecked a few times in the code described above.<\/p>\n\n\n\nimports<\/code>.\nThe folder will contain a sub folder named bridge<\/code>.\nSee Spiderwiz Logging System<\/a> for more details.<\/p>\n\n\n\nImport-Export\ndelegation<\/h2>\n\n\n\n
ObjectCodes.RawExport<\/code> and ObjectCodes.RawImport<\/code> constants that we\nuse in BridgeMain.getProducedObjects()<\/code>\nand BridgeMain.getConsumedObjects()<\/code>\nrespectively. These are not needed for the example we implemented above, but\nmight be very useful in the following scenario:<\/p>\n\n\n\nRawImport<\/code> data\nobjects. The consumers are the applications that run on a development system,\nwhich parse the data and produce specific data objects. Similarly, the\ndevelopment applications encapsulate exported data in RawExport<\/code> data objects, which are received by the production bridge\nand delivered as raw data to the foreign system. This is exactly what the\nbuilt-in data objects identified by the said constants do.<\/p>\n\n\n\nimport-n<\/code>\nconfiguration property as above, in which case the property define direct\naccess parameters to the foreign system, or we can omit this property all\ntogether and instead install somewhere a \u201ccatch all\u201d bridge that connects to\nthe foreign system and exchanges the necessary objects with the Chat Room Bridge<\/em> described here. The\nlatter works without any change whether configured like in the first or the\nsecond way.<\/p>\n\n\n\nRemoteMain<\/code>:<\/p>\n\n\n\npackage org.spiderwiz.tutorial.lesson11.remote;\n\nimport org.spiderwiz.tutorial.objectLib.ConsoleMain;\n\n\/**\n * Provides the entry point of the application. Initializes and executes the Spiderwiz framework.\n *\/\npublic class RemoteMain extends ConsoleMain{\n private static final String ROOT_DIRECTORY = "";\n private static final String CONFIG_FILE_NAME = "remote.conf";\n private static final String APP_NAME = "Remote Import\/Export";\n private static final String APP_VERSION = "Z1.01"; \/\/ Version Z1.01: Initial version\n\n public RemoteMain() {\n super(ROOT_DIRECTORY, CONFIG_FILE_NAME, APP_NAME, APP_VERSION);\n }\n\n \/**\n * Application entry point. Instantiate the class and initialize the instance.\n * \n * @param args the command line arguments. Not used in this application.\n *\/\n public static void main(String[] args) {\n new RemoteMain().init();\n }\n\n \/**\n * @return a predefined code for importing raw data into a remote service\n *\/\n @Override\n protected String[] getProducedObjects() {\n return new String[]{ObjectCodes.RawImport};\n }\n\n \/**\n * @return a predefined code for exporting raw data from a remote service\n *\/\n @Override\n protected String[] getConsumedObjects() {\n return new String[]{ObjectCodes.RawExport};\n }\n\n \/**\n * Process an input line - nothing to process in our case.\n * @param line The input line\n * @return true\n *\/\n @Override\n protected boolean processConsoleLine(String line) {\n return true;\n }\n}<\/pre><\/div>\n\n\n\nConsoleMain<\/code> extension, except that it produces ObjectCodes.RawImport<\/code> (line 31) and consumes ObjectCodes.RawExport<\/code> (line 29). Nothing else is required since\neverything is already built into the framework.<\/p>\n\n\n\n[log folder]\/tests\/Remote\/Logs\n[producer-1]ip=localhost;port=10001\n[import-1]infile=\/tests\/Remote\/ImportIn.txt;outfile=\/tests\/Remote\/ImportOut.txt;name=bridge<\/pre><\/div>\n\n\n\n
bridge.conf<\/code>:<\/p>\n\n\n\n[log folder]\/tests\/Bridge\/Logs\n[producer-1]ip=localhost;port=10001<\/pre><\/div>\n\n\n\n
The magic of\nSpiderAdmin<\/h2>\n\n\n\n
[log folder]\/tests\/Bridge\/Logs\n[producer-1]ip=localhost;port=10001\n[-import-1]infile=\/tests\/Remote\/ImportIn.txt;outfile=\/tests\/Remote\/ImportOut.txt;name=bridge<\/pre><\/div>\n\n\n\n
![\"\"](\"http:\/\/spiderwiz.org\/project\/wp-content\/uploads\/2020\/08\/lesson-11-1-1024x520.png\")
<\/figure>\n\n\n\n![\"\"](\"http:\/\/spiderwiz.org\/project\/wp-content\/uploads\/2020\/08\/lesson-11-2-1024x434.png\")
<\/figure>\n\n\n\n![\"\"](\"http:\/\/spiderwiz.org\/project\/wp-content\/uploads\/2020\/08\/lesson-11-3-1024x429.png\")
<\/figure>\n\n\n\nimport-1<\/code> property, like this:<\/p>\n\n\n\n![\"\"](\"http:\/\/spiderwiz.org\/project\/wp-content\/uploads\/2020\/08\/lesson-11-4.png\")
<\/figure>\n\n\n\nConnection to ImportIn.txt succeeded<\/code><\/strong><\/p>\n\n\n\n![\"\"](\"http:\/\/spiderwiz.org\/project\/wp-content\/uploads\/2020\/08\/lesson-11-5-1024x593.png\")
<\/figure>\n\n\n\n