about making inter era message exchange default for javaApp interface

Author: thsc42

src/net/sharksystem/asap/apps/ASAPJavaApplicationFS.java

@@ -30,6 +30,11 @@ private ASAPJavaApplicationFS(CharSequence owner, CharSequence rootFolder, Colle
             // ensure that supported format engine are up and running
             for(CharSequence format : supportedFormats) {
                 this.multiEngine.createEngineByFormat(format);
+
+                // setup inter era message delivery
+                System.out.println(this.getLogStart() + "setup inter era message exchange for " + format);
+                ASAPEngine engine = multiEngine.getEngineByFormat(format);
+                new ASAPSingleProcessOnlineMessageSender(this.multiEngine, engine);
             }
         }
     }

test/net/sharksystem/asap/ASAPJavaApplicationTests.java

@@ -35,30 +35,85 @@ public void usageTest() throws IOException, ASAPException, InterruptedException
         asapJavaApplicationAlice.sendASAPMessage(APP_FORMAT, "yourSchema://yourURI", recipients, TESTMESSAGE);
         asapJavaApplicationAlice.setASAPMessageReceivedListener(APP_FORMAT, new ListenerExample());
 
+        // create bob engine
+        ASAPJavaApplication asapJavaApplicationBob =
+                ASAPJavaApplicationFS.createASAPJavaApplication(BOB, BOB_ROOT_FOLDER, formats);
+
+        ListenerExample listenerBob = new ListenerExample();
+        asapJavaApplicationBob.setASAPMessageReceivedListener(APP_FORMAT, listenerBob);
+
         ///////////////////////////////////////////////////////////////////////////////////////////////////
         //                                        create a tcp connection                                //
         ///////////////////////////////////////////////////////////////////////////////////////////////////
 
+        // create connections for both sides
+        TCPChannel aliceChannel = new TCPChannel(PORT, true, "a2b");
+        TCPChannel bobChannel = new TCPChannel(PORT, false, "b2a");
+
+        aliceChannel.start(); bobChannel.start();
+        // wait to connect
+        aliceChannel.waitForConnection(); bobChannel.waitForConnection();
+
+        ///////////////////////////////////////////////////////////////////////////////////////////////////
+        //                                        run asap session                                       //
+        ///////////////////////////////////////////////////////////////////////////////////////////////////
+
+        // run engine as thread
+        ASAPHandleConnectionThread aliceEngineThread = new ASAPHandleConnectionThread(asapJavaApplicationAlice,
+                aliceChannel.getInputStream(), aliceChannel.getOutputStream());
+
+        aliceEngineThread.start();
+
+        // let's start communication
+        asapJavaApplicationBob.handleConnection(bobChannel.getInputStream(), bobChannel.getOutputStream());
+
+        // wait until communication probably ends
+        Thread.sleep(2000); System.out.flush(); System.err.flush();
+        // close connections: note ASAPEngine does NOT close any connection!!
+        aliceChannel.close(); bobChannel.close(); Thread.sleep(1000);
+
+        ///////////////////////////////////////////////////////////////////////////////////////////////////
+        //                                            test results                                       //
+        ///////////////////////////////////////////////////////////////////////////////////////////////////
+
+        // received?
+        Assert.assertTrue(listenerBob.hasReceivedMessage());
+    }
+
+    @Test
+    public void onlineTest() throws IOException, ASAPException, InterruptedException {
+        ASAPEngineFS.removeFolder(TESTS_ROOT_FOLDER);
+
+        Collection<CharSequence> formats = new HashSet<>();
+        formats.add(APP_FORMAT);
+
+        // create alice engine
+        ASAPJavaApplication asapJavaApplicationAlice =
+                ASAPJavaApplicationFS.createASAPJavaApplication(ALICE, ALICE_ROOT_FOLDER, formats);
+
         // create bob engine
         ASAPJavaApplication asapJavaApplicationBob =
                 ASAPJavaApplicationFS.createASAPJavaApplication(BOB, BOB_ROOT_FOLDER, formats);
 
+        // create Bob receiver
         ListenerExample listenerBob = new ListenerExample();
         asapJavaApplicationBob.setASAPMessageReceivedListener(APP_FORMAT, listenerBob);
 
+
+        ///////////////////////////////////////////////////////////////////////////////////////////////////
+        //                                        create a tcp connection                                //
+        ///////////////////////////////////////////////////////////////////////////////////////////////////
+
         // create connections for both sides
         TCPChannel aliceChannel = new TCPChannel(PORT, true, "a2b");
         TCPChannel bobChannel = new TCPChannel(PORT, false, "b2a");
 
-        aliceChannel.start();
-        bobChannel.start();
-
+        aliceChannel.start(); bobChannel.start();
         // wait to connect
-        aliceChannel.waitForConnection();
-        bobChannel.waitForConnection();
+        aliceChannel.waitForConnection(); bobChannel.waitForConnection();
 
         ///////////////////////////////////////////////////////////////////////////////////////////////////
-        //                                        run asap connection                                    //
+        //                                        run asap session                                       //
         ///////////////////////////////////////////////////////////////////////////////////////////////////
 
         // run engine as thread
@@ -70,21 +125,17 @@ public void usageTest() throws IOException, ASAPException, InterruptedException
         // let's start communication
         asapJavaApplicationBob.handleConnection(bobChannel.getInputStream(), bobChannel.getOutputStream());
 
-        // wait until communication probably ends
-        System.out.flush();
-        System.err.flush();
-        Thread.sleep(2000);
-        System.out.flush();
-        System.err.flush();
+        // nothing really spectaculare has happend until now
 
+        // create a message and send message from alice to bob over an existing connection
+        Collection<CharSequence> recipients = new HashSet<>();
+        recipients.add(BOB);
+      asapJavaApplicationAlice.sendASAPMessage(APP_FORMAT, "yourSchema://yourURI", recipients, TESTMESSAGE);
+
+        // wait until communication probably ends
+        Thread.sleep(2000); System.out.flush(); System.err.flush();
         // close connections: note ASAPEngine does NOT close any connection!!
-        aliceChannel.close();
-        bobChannel.close();
-        System.out.flush();
-        System.err.flush();
-        Thread.sleep(1000);
-        System.out.flush();
-        System.err.flush();
+        aliceChannel.close(); bobChannel.close(); Thread.sleep(1000);
 
         ///////////////////////////////////////////////////////////////////////////////////////////////////
         //                                            test results                                       //