From bb808591a6a7c2993949f2ed6e153d0ac08c5b88 Mon Sep 17 00:00:00 2001
From: Marnie McCormack <marnie@apache.org>
Date: Fri, 3 Nov 2006 13:55:57 +0000
Subject: Initial test for AMQSession changes from QPID-66

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470818 13f79535-47bb-0310-9956-ffa450edef68
---
 .../src/org/apache/qpid/client/TestAMQSession.java | 86 ++++++++++++++++++++++
 1 file changed, 86 insertions(+)
 create mode 100644 java/client/test/src/org/apache/qpid/client/TestAMQSession.java

(limited to 'java/client/test/src')

diff --git a/java/client/test/src/org/apache/qpid/client/TestAMQSession.java b/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
new file mode 100644
index 0000000000..c734a67122
--- /dev/null
+++ b/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
@@ -0,0 +1,86 @@
+/*
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.qpid.client;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.Assert;
+import org.apache.qpid.AMQException;
+import org.apache.qpid.client.transport.TransportConnection;
+import org.apache.qpid.client.vmbroker.AMQVMBrokerCreationException;
+import org.apache.qpid.url.URLSyntaxException;
+
+import javax.jms.JMSException;
+import javax.jms.TopicSubscriber;
+
+import junit.framework.JUnit4TestAdapter;
+
+/**
+ * These tests need a broker to be running on locahost:5672 so not added to
+ */
+public class TestAMQSession {
+
+    private AMQSession _session;
+    private AMQTopic _topic;
+    private AMQQueue _queue;
+
+    @Before
+    public void setUp() throws AMQException, URLSyntaxException, JMSException {
+        //initialise the variables we need for testing
+        startVmBrokers();
+        AMQConnection connection = new AMQConnection("vm://:1", "guest", "guest", "fred", "/test");
+        _topic = new AMQTopic("mytopic");
+        _queue = new AMQQueue("myqueue");
+        _session = (AMQSession) connection.createSession(false, AMQSession.NO_ACKNOWLEDGE);
+    }
+
+    @Test
+    public void testCreateSubscriber() throws JMSException {
+        TopicSubscriber subscriber = _session.createSubscriber(_topic);
+        Assert.assertEquals("Topic names should match from TopicSubscriber",_topic.getTopicName(),subscriber.getTopic().getTopicName());
+
+        subscriber = _session.createSubscriber(_topic,"abc",false);
+        Assert.assertEquals("Topic names should match from TopicSubscriber with selector",_topic.getTopicName(),subscriber.getTopic().getTopicName());
+    }
+
+    @Test
+    public void testCreateDurableSubscriber() throws JMSException {
+         TopicSubscriber subscriber = _session.createDurableSubscriber(_topic, "mysubname");
+         Assert.assertEquals("Topic names should match from durable TopicSubscriber",_topic.getTopicName(),subscriber.getTopic().getTopicName());
+
+        subscriber = _session.createDurableSubscriber(_topic,"mysubname","abc",false);
+        Assert.assertEquals("Topic names should match from durable TopicSubscriber with selector",_topic.getTopicName(),subscriber.getTopic().getTopicName());
+    }
+
+    public static junit.framework.Test suite()
+    {
+        return new JUnit4TestAdapter(TestAMQSession.class);
+    }
+
+    private void startVmBrokers()
+    {
+        try
+        {
+            TransportConnection.createVMBroker(1);
+        }
+        catch (AMQVMBrokerCreationException e)
+        {
+            Assert.fail("Unable to create VM Broker: " + e.getMessage());
+        }
+    }
+}
-- 
cgit v1.2.1