1 22 package org.jboss.test.jbossmq.test; 23 24 import org.jboss.mq.ConnectionToken; 25 import org.jboss.mq.il.ClientIL; 26 import org.jboss.mq.server.ClientMonitorInterceptor; 27 import org.jboss.test.jbossmq.JBossMQMicrocontainerTest; 28 import org.jboss.test.jbossmq.support.MockClientIL; 29 30 36 public class ClientMonitorConnectionRaceUnitTestCase extends JBossMQMicrocontainerTest 37 { 38 public ClientMonitorConnectionRaceUnitTestCase(String name) 39 { 40 super(name); 41 } 42 43 public void testRace() throws Exception 44 { 45 ClientMonitorInterceptor monitor = (ClientMonitorInterceptor) getBean("ClientMonitorInterceptor"); 46 ClientIL client = new MockClientIL(); 47 48 ConnectionToken original = new ConnectionToken(null, client, "session"); 50 monitor.ping(original, System.currentTimeMillis()); 51 assertNotNull(monitor.peekClientStats(original)); 52 53 ConnectionToken withID = new ConnectionToken("test", client, "session"); 55 monitor.ping(withID, System.currentTimeMillis()); 56 assertNull("Token without id should be removed", monitor.peekClientStats(original)); 57 assertNotNull(monitor.peekClientStats(withID)); 58 } 59 } 60 | Popular Tags |