You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/03/04 15:13:15 UTC
qpid-jms git commit: Add some tests for later.
Repository: qpid-jms
Updated Branches:
refs/heads/master a8e68e4e6 -> a2a192138
Add some tests for later.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/a2a19213
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/a2a19213
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/a2a19213
Branch: refs/heads/master
Commit: a2a192138fd96389fe0c7d0e859ac4af192e0cae
Parents: a8e68e4
Author: Timothy Bish <ta...@gmail.com>
Authored: Wed Mar 4 09:12:51 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Wed Mar 4 09:12:51 2015 -0500
----------------------------------------------------------------------
.../apache/qpid/jms/session/JmsSessionTest.java | 83 ++++++++++++++++++++
1 file changed, 83 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/a2a19213/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java
index e164be8..375271a 100644
--- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java
+++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java
@@ -16,15 +16,25 @@
*/
package org.apache.qpid.jms.session;
+import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+import java.util.concurrent.TimeUnit;
+
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
+import javax.jms.TemporaryQueue;
+import javax.jms.TemporaryTopic;
+import javax.jms.Topic;
+import org.apache.activemq.broker.jmx.BrokerViewMBean;
import org.apache.qpid.jms.support.AmqpTestSupport;
+import org.apache.qpid.jms.support.Wait;
+import org.junit.Ignore;
import org.junit.Test;
/**
@@ -112,4 +122,77 @@ public class JmsSessionTest extends AmqpTestSupport {
LOG.info("Caught exception on create producer: {}", ex);
}
}
+
+ @Test(timeout=30000)
+ public void testCreateTemporaryQueue() throws Exception {
+ connection = createAmqpConnection();
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Queue queue = session.createTemporaryQueue();
+ assertNotNull(queue);
+ assertTrue(queue instanceof TemporaryQueue);
+
+ final BrokerViewMBean broker = getProxyToBroker();
+ assertEquals(1, broker.getTemporaryQueues().length);
+ }
+
+ @Ignore("Delete of Temporary destinations not yet supported.")
+ @Test(timeout=30000)
+ public void testDeleteTemporaryQueue() throws Exception {
+ connection = createAmqpConnection();
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Queue queue = session.createTemporaryQueue();
+ assertNotNull(queue);
+ assertTrue(queue instanceof TemporaryQueue);
+
+ final BrokerViewMBean broker = getProxyToBroker();
+ assertEquals(1, broker.getTemporaryQueues().length);
+
+ TemporaryQueue tempQueue = (TemporaryQueue) queue;
+ tempQueue.delete();
+
+ assertTrue("Temp Queue should be deleted.", Wait.waitFor(new Wait.Condition() {
+
+ @Override
+ public boolean isSatisified() throws Exception {
+ return broker.getTemporaryQueues().length == 0;
+ }
+ }, TimeUnit.SECONDS.toMillis(30), TimeUnit.MILLISECONDS.toMillis(50)));
+ }
+
+ @Ignore("Temporary Topics not supported in AMQ yet.")
+ @Test(timeout=30000)
+ public void testCreateTemporaryTopic() throws Exception {
+ connection = createAmqpConnection();
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Topic topic = session.createTemporaryTopic();
+ assertNotNull(topic);
+ assertTrue(topic instanceof TemporaryTopic);
+
+ final BrokerViewMBean broker = getProxyToBroker();
+ assertEquals(1, broker.getTemporaryTopics().length);
+ }
+
+ @Ignore("Temporary Topics not supported in AMQ yet.")
+ @Test(timeout=30000)
+ public void testDeleteTemporaryTopic() throws Exception {
+ connection = createAmqpConnection();
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Topic topic = session.createTemporaryTopic();
+ assertNotNull(topic);
+ assertTrue(topic instanceof TemporaryTopic);
+
+ final BrokerViewMBean broker = getProxyToBroker();
+ assertEquals(1, broker.getTemporaryTopics().length);
+
+ TemporaryTopic tempTopic = (TemporaryTopic) topic;
+ tempTopic.delete();
+
+ assertTrue("Temp Topic should be deleted.", Wait.waitFor(new Wait.Condition() {
+
+ @Override
+ public boolean isSatisified() throws Exception {
+ return broker.getTemporaryTopics().length == 0;
+ }
+ }, TimeUnit.SECONDS.toMillis(30), TimeUnit.MILLISECONDS.toMillis(50)));
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org