SEAMJMS-34 Test case clean up, added pause in between to add more tim…

…e between checks.
seam · Jun 29, 2011 · 6071e29 · 6071e29
1 parent 348038f
commit 6071e29
Show file tree

Hide file tree

Showing 3 changed files with 37 additions and 31 deletions.
diff --git a/impl/src/main/java/org/jboss/seam/jms/bridge/RouteBuilderImpl.java b/impl/src/main/java/org/jboss/seam/jms/bridge/RouteBuilderImpl.java
@@ -44,11 +44,6 @@ public class RouteBuilderImpl implements RouteBuilder, java.io.Serializable {
     @Inject
     BeanManager beanManager;
 
-    public RouteBuilderImpl() {
-        Logger log = Logger.getLogger(RouteBuilderImpl.class);
-        log.debug("Creating a new RouteBuilder()");
-    }
-
     @Override
     public void handleStartup(@Observes ServletContext servletContext) {
         log.debug("Starting up Seam JMS via ServletContext callback.");
@@ -78,27 +73,4 @@ private void createListener(Route ingressRoute) {
             this.messageBuilder.createMessageConsumer(d, listener);
         }
     }
-    /*
-     @Override
-     public void registerDurableIngressRoute(Route ingressRoute, String clientId) {
-         if(ingressRoute.getType() == RouteType.INGRESS) {
-             ingressRoute.build(beanManager);
-             ClassLoader prevCl = Thread.currentThread().getContextClassLoader();
-             log.debug("About to create listener for route " + ingressRoute);
-             log.debug("Routes: " + ingressRoute.getDestinations());
-             for (Destination d : ingressRoute.getDestinations()) {
-                     IngressMessageListener listener = new IngressMessageListener(
-                                     beanManager, prevCl, ingressRoute);
-                     this.messageBuilder.createDurableSubscriber(d, clientId, listener);
-             }
-         } else {
-             throw new IllegalArgumentException("Route "+ingressRoute+" is not valid, it must be an ingress route.");
-         }
-     }
-
-     @Override
-     public void unregisterRoute(String clientId) {
-         this.messageBuilder.unsubscribe(clientId);
-     }
-     */
 }
diff --git a/impl/src/test/java/org/jboss/seam/jms/test/builder/topic/TopicBuilderImplTest.java b/impl/src/test/java/org/jboss/seam/jms/test/builder/topic/TopicBuilderImplTest.java
@@ -93,24 +93,27 @@ public void testListen() {
 	}
 
 	@Test
-	public void testSendMap() {
+	public void testSendMap() throws Exception {
 		Map mapData = new HashMap<String,String>();
 		TopicTestListener ttl = new TopicTestListener();
 		topicBuilder.newBuilder().destination("jms/T3").listen(ttl).sendMap(mapData);
+		Thread.sleep(5000);
 		testMessageSent(true,MapMessage.class,ttl);
 	}
 	@Test
-	public void testSendString() {
+	public void testSendString() throws Exception {
 		String data = "new data";
 		TopicTestListener ttl = new TopicTestListener();
 		topicBuilder.newBuilder().destination("jms/T1").listen(ttl).sendString(data);
+		Thread.sleep(5000);
 		testMessageSent(true,TextMessage.class,ttl);
 	}
 	@Test
-	public void testSendObject() {
+	public void testSendObject() throws Exception {
 		Object data = 33L;
 		TopicTestListener ttl = new TopicTestListener();
 		topicBuilder.newBuilder().destination("jms/T2").listen(ttl).sendObject(data);
+		Thread.sleep(5000);
 		testMessageSent(true,ObjectMessage.class,ttl);
 	}
 }
diff --git a/impl/src/test/java/org/jboss/seam/jms/test/routeBuilder/RouteBuilderImplTest.java b/impl/src/test/java/org/jboss/seam/jms/test/routeBuilder/RouteBuilderImplTest.java
@@ -0,0 +1,31 @@
+package org.jboss.seam.jms.test.routeBuilder;
+
+import javax.inject.Inject;
+import javax.jms.JMSException;
+
+import junit.framework.Assert;
+
+import org.jboss.arquillian.api.Deployment;
+import org.jboss.arquillian.junit.Arquillian;
+import org.jboss.seam.jms.bridge.RouteBuilder;
+import org.jboss.seam.jms.bridge.RouteBuilderImpl;
+import org.jboss.seam.jms.test.Util;
+import org.jboss.shrinkwrap.api.Archive;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+@RunWith(Arquillian.class)
+public class RouteBuilderImplTest {
+	@Deployment
+    public static Archive<?> createDeployment() {
+        return Util.createDeployment(RouteBuilderImpl.class);
+    }
+
+	@Inject RouteBuilder routeBuilder;
+
+	@Test
+	public void testInit() throws JMSException {
+		routeBuilder.init();
+		Assert.assertTrue(true);
+	}
+}