[jboss-cvs] JBoss Messaging SVN: r4632 - trunk/tests/src/org/jboss/messaging/tests/unit/core/server/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2008-07-04 06:19:10 -0400 (Fri, 04 Jul 2008)
New Revision: 4632

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/server/impl/MessagingServerImplTest.java
Log:
Added test to make sure server can be started and stopped multiple times


Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/server/impl/MessagingServerImplTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/server/impl/MessagingServerImplTest.java	2008-07-04 10:02:50 UTC (rev 4631)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/server/impl/MessagingServerImplTest.java	2008-07-04 10:19:10 UTC (rev 4632)
@@ -204,6 +204,8 @@
       
       EasyMock.reset(sm, rs, pd);
       
+      assertNotNull(server.getQueueSettingsRepository());
+      
       //Starting again should do nothing
       
       EasyMock.replay(sm, rs, pd);
@@ -280,6 +282,42 @@
       assertFalse(server.isStarted());
       
       EasyMock.verify(sm, rs, pd);
+      
+      EasyMock.reset(sm, rs, pd);
+      
+      EasyMock.expect(rs.getDispatcher()).andReturn(pd);
+      EasyMock.expect(sm.isStarted()).andStubReturn(true);
+      EasyMock.expect(rs.isStarted()).andStubReturn(true);
+      rs.addRemotingSessionListener(EasyMock.isA(ConnectionManagerImpl.class));
+      sm.loadBindings(EasyMock.isA(QueueFactoryImpl.class), EasyMock.isA(ArrayList.class), EasyMock.isA(ArrayList.class));
+      sm.loadMessages(EasyMock.isA(PostOfficeImpl.class), EasyMock.isA(Map.class));
+            
+      pd.register(EasyMock.isA(MessagingServerPacketHandler.class));
+      
+      EasyMock.replay(sm, rs, pd);
+                 
+      //Should be able to start again
+      server.start();
+      
+      EasyMock.verify(sm, rs, pd);
+      
+      assertTrue(server.isStarted());
+      
+      assertNotNull(server.getQueueSettingsRepository());
+      
+      EasyMock.reset(sm, rs, pd);
+      
+      pd.unregister(0);
+      rs.removeRemotingSessionListener(EasyMock.isA(ConnectionManagerImpl.class));
+      
+      EasyMock.replay(sm, rs, pd);
+      
+      //And stop
+      server.stop();
+      
+      assertFalse(server.isStarted());
+      
+      EasyMock.verify(sm, rs, pd);
    }
    
    public void testCreateConnectionIncompatibleVersion() throws Exception