Changeset 82 for trunk/src/test/java/omq

Timestamp:

07/05/13 16:51:11 (11 years ago)

Author:

stoda

Message:

I've done some javadocs...

File:

• trunk/src/test/java/omq/test/persistence/PersistentTest.java (modified) (2 diffs)

trunk/src/test/java/omq/test/persistence/PersistentTest.java

@@ -85 +85 @@
                 serverBroker.bind(MESSAGE, msgImpl, msgImplProps);
 
+                // Stop the serverBroker
+                serverBroker.stopBroker();
+
                 Broker clientBroker = new Broker(clientProps);
                 Message iMsg = clientBroker.lookup(MESSAGE, Message.class);
@@ -98 +101 @@
                 Thread.sleep(15000);
 
+                // Restart the server and listen to the new messages
+                serverBroker = new Broker(serverProps);
+                msgImpl = new MessageImpl();
+                serverBroker.bind(MESSAGE, msgImpl, msgImplProps);
+
                 actual = iMsg.getMessage();