You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2015/01/20 14:20:50 UTC

karaf git commit: Improve JmsTest itest to use OSGi service lookup for the connection factory instead of Thread.sleep()

Repository: karaf
Updated Branches:
  refs/heads/karaf-3.0.x fa99b941d -> e5736e630


Improve JmsTest itest to use OSGi service lookup for the connection factory instead of Thread.sleep()


Project: http://git-wip-us.apache.org/repos/asf/karaf/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf/commit/e5736e63
Tree: http://git-wip-us.apache.org/repos/asf/karaf/tree/e5736e63
Diff: http://git-wip-us.apache.org/repos/asf/karaf/diff/e5736e63

Branch: refs/heads/karaf-3.0.x
Commit: e5736e630dad3d0f56e88665774c957827f7a7f1
Parents: fa99b94
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Tue Jan 20 14:20:11 2015 +0100
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Tue Jan 20 14:20:11 2015 +0100

----------------------------------------------------------------------
 itests/pom.xml                                            | 6 ++++++
 itests/src/test/java/org/apache/karaf/itests/JmsTest.java | 5 +++--
 2 files changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/karaf/blob/e5736e63/itests/pom.xml
----------------------------------------------------------------------
diff --git a/itests/pom.xml b/itests/pom.xml
index 6d69b93..4bc0753 100644
--- a/itests/pom.xml
+++ b/itests/pom.xml
@@ -74,6 +74,12 @@
         </dependency>
 
         <dependency>
+            <groupId>org.apache.geronimo.specs</groupId>
+            <artifactId>geronimo-jms_1.1_spec</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
             <groupId>org.apache.karaf.package</groupId>
             <artifactId>org.apache.karaf.package.core</artifactId>
         </dependency>

http://git-wip-us.apache.org/repos/asf/karaf/blob/e5736e63/itests/src/test/java/org/apache/karaf/itests/JmsTest.java
----------------------------------------------------------------------
diff --git a/itests/src/test/java/org/apache/karaf/itests/JmsTest.java b/itests/src/test/java/org/apache/karaf/itests/JmsTest.java
index e2ef126..e728909 100644
--- a/itests/src/test/java/org/apache/karaf/itests/JmsTest.java
+++ b/itests/src/test/java/org/apache/karaf/itests/JmsTest.java
@@ -23,6 +23,7 @@ import org.ops4j.pax.exam.spi.reactors.PerClass;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.assertEquals;
 
+import javax.jms.ConnectionFactory;
 import javax.management.MBeanServerConnection;
 import javax.management.ObjectName;
 import javax.management.remote.JMXConnector;
@@ -45,7 +46,7 @@ public class JmsTest extends KarafTestSupport {
         // jms:create command
         System.out.println(executeCommand("jms:create -t ActiveMQ -u karaf -p karaf --url tcp://localhost:61616 test"));
         // give time to fileinstall to load the blueprint file
-        Thread.sleep(5000);
+        getOsgiService(ConnectionFactory.class, "name=test", 30000);
         // jms:connectionfactories command
         String connectionFactories = executeCommand("jms:connectionfactories");
         System.out.println(connectionFactories);
@@ -98,7 +99,7 @@ public class JmsTest extends KarafTestSupport {
             ObjectName name = new ObjectName("org.apache.karaf:type=jms,name=root");
             // create operation
             connection.invoke(name, "create", new String[]{ "testMBean", "activemq", "tcp://localhost:61616", "karaf", "karaf" }, new String[]{ "java.lang.String", "java.lang.String", "java.lang.String", "java.lang.String", "java.lang.String" });
-            Thread.sleep(5000);
+            getOsgiService(ConnectionFactory.class, "name=testMBean", 30000);
             List<String> connectionFactories = (List<String>) connection.getAttribute(name, "Connectionfactories");
             assertEquals(true, connectionFactories.size() >= 1);
             // send operation