Index: trunk/src/test/java/omq/test/persistence/PersistentTest.java
===================================================================
--- trunk/src/test/java/omq/test/persistence/PersistentTest.java	(revision 81)
+++ trunk/src/test/java/omq/test/persistence/PersistentTest.java	(revision 82)
@@ -85,4 +85,7 @@
 		serverBroker.bind(MESSAGE, msgImpl, msgImplProps);
 
+		// Stop the serverBroker
+		serverBroker.stopBroker();
+
 		Broker clientBroker = new Broker(clientProps);
 		Message iMsg = clientBroker.lookup(MESSAGE, Message.class);
@@ -98,4 +101,9 @@
 		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();