Fixed missing connection factory reference.

seam · Nov 28, 2011 · 0a1d494 · 0a1d494
1 parent 9ac4038
commit 0a1d494
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 6 deletions.
diff --git a/testsuite/src/test/java/org/jboss/seam/jms/test/builder/queue/QueueBuilderImplTest.java b/testsuite/src/test/java/org/jboss/seam/jms/test/builder/queue/QueueBuilderImplTest.java
@@ -23,6 +23,7 @@
 
 import javax.annotation.Resource;
 import javax.inject.Inject;
+import javax.jms.ConnectionFactory;
 import javax.jms.MapMessage;
 import javax.jms.ObjectMessage;
 import javax.jms.Queue;
@@ -91,13 +92,15 @@ public void testListen() {
     Queue qb;
     @Resource(mappedName = "jms/QC")
     Queue qc;
+
+    @Resource(mappedName="/ConnectionFactory") ConnectionFactory cf;
 
     @Test
     public void testSendMap() {
         QueueTestListener ttl = new QueueTestListener();
         Map mapData = new HashMap<String, String>();
         mapData.put("my key", "my value");
-        queueBuilder.newBuilder().transacted().sessionMode(Session.SESSION_TRANSACTED).destination(qa).listen(ttl).sendMap(mapData);
+        queueBuilder.newBuilder().connectionFactory(cf).transacted().sessionMode(Session.SESSION_TRANSACTED).destination(qa).listen(ttl).sendMap(mapData);
         DeploymentFactory.pause(5000);
         testMessageSent(true, MapMessage.class, ttl);
     }
@@ -106,7 +109,7 @@ public void testSendMap() {
     public void testSendString() {
         QueueTestListener ttl = new QueueTestListener();
         String data = "new data";
-        queueBuilder.newBuilder().transacted().sessionMode(Session.SESSION_TRANSACTED).destination(qb).listen(ttl).sendString(data);
+        queueBuilder.newBuilder().connectionFactory(cf).transacted().sessionMode(Session.SESSION_TRANSACTED).destination(qb).listen(ttl).sendString(data);
         DeploymentFactory.pause(5000);
         testMessageSent(true, TextMessage.class, ttl);
     }
@@ -115,7 +118,7 @@ public void testSendString() {
     public void testSendObject() {
         QueueTestListener ttl = new QueueTestListener();
         Serializable data = 33L;
-        queueBuilder.newBuilder().transacted().sessionMode(Session.SESSION_TRANSACTED).destination(qc).listen(ttl).sendObject(data);
+        queueBuilder.newBuilder().connectionFactory(cf).transacted().sessionMode(Session.SESSION_TRANSACTED).destination(qc).listen(ttl).sendObject(data);
         DeploymentFactory.pause(5000);
         testMessageSent(true, ObjectMessage.class, ttl);
     }

diff --git a/testsuite/src/test/java/org/jboss/seam/jms/test/builder/topic/TopicBuilderImplTest.java b/testsuite/src/test/java/org/jboss/seam/jms/test/builder/topic/TopicBuilderImplTest.java
@@ -23,6 +23,7 @@
 
 import javax.annotation.Resource;
 import javax.inject.Inject;
+import javax.jms.ConnectionFactory;
 import javax.jms.MapMessage;
 import javax.jms.ObjectMessage;
 import javax.jms.Session;
@@ -88,28 +89,30 @@ public void testListen() {
         @Resource(mappedName="jms/T1") Topic t1;
         @Resource(mappedName="jms/T2") Topic t2;
 
+        @Resource(mappedName="/ConnectionFactory") ConnectionFactory cf;
+
 
 	@Test
 	public void testSendMap() {
 		Map mapData = new HashMap<String,String>();
 		TopicTestListener ttl = new TopicTestListener();
-		topicBuilder.newBuilder().transacted().sessionMode(Session.SESSION_TRANSACTED).destination(t3).listen(ttl).sendMap(mapData);
+		topicBuilder.newBuilder().connectionFactory(cf).transacted().sessionMode(Session.SESSION_TRANSACTED).destination(t3).listen(ttl).sendMap(mapData);
 		DeploymentFactory.pause(5000);
 		testMessageSent(true,MapMessage.class,ttl);
 	}
 	@Test
 	public void testSendString() {
 		String data = "new data";
 		TopicTestListener ttl = new TopicTestListener();
-		topicBuilder.newBuilder().transacted().sessionMode(Session.SESSION_TRANSACTED).destination(t1).listen(ttl).sendString(data);
+		topicBuilder.newBuilder().connectionFactory(cf).transacted().sessionMode(Session.SESSION_TRANSACTED).destination(t1).listen(ttl).sendString(data);
 		DeploymentFactory.pause(5000);
 		testMessageSent(true,TextMessage.class,ttl);
 	}
 	@Test
 	public void testSendObject() {
 		Serializable data = 33L;
 		TopicTestListener ttl = new TopicTestListener();
-		topicBuilder.newBuilder().transacted().sessionMode(Session.SESSION_TRANSACTED).destination(t2).listen(ttl).sendObject(data);
+		topicBuilder.newBuilder().connectionFactory(cf).transacted().sessionMode(Session.SESSION_TRANSACTED).destination(t2).listen(ttl).sendObject(data);
 		DeploymentFactory.pause(5000);
 		testMessageSent(true,ObjectMessage.class,ttl);
 	}