1 files changed, 21 insertions, 2 deletions
diff --git a/java/client/test/src/org/apache/qpid/client/TestAMQSession.java b/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
index c734a67122..78086706ec 100644
--- a/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
+++ b/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
@@ -27,6 +27,7 @@ import org.apache.qpid.url.URLSyntaxException;
 
 import javax.jms.JMSException;
 import javax.jms.TopicSubscriber;
+import javax.jms.QueueReceiver;
 
 import junit.framework.JUnit4TestAdapter;
 
@@ -60,13 +61,31 @@ public class TestAMQSession {
 
     @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());
+        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());
     }
 
+    @Test
+    public void testCreateQueueReceiver() throws JMSException {
+        QueueReceiver receiver = _session.createQueueReceiver(_queue);
+        Assert.assertEquals("Queue names should match from QueueReceiver",_queue.getQueueName(),receiver.getQueue().getQueueName());
+
+        receiver = _session.createQueueReceiver(_queue, "abc");
+        Assert.assertEquals("Queue names should match from QueueReceiver with selector",_queue.getQueueName(),receiver.getQueue().getQueueName());
+    }
+
+    @Test
+     public void testCreateReceiver() throws JMSException {
+        QueueReceiver receiver = _session.createReceiver(_queue);
+        Assert.assertEquals("Queue names should match from QueueReceiver",_queue.getQueueName(),receiver.getQueue().getQueueName());
+
+        receiver = _session.createReceiver(_queue, "abc");
+        Assert.assertEquals("Queue names should match from QueueReceiver with selector",_queue.getQueueName(),receiver.getQueue().getQueueName());
+    }
+
     public static junit.framework.Test suite()
     {
         return new JUnit4TestAdapter(TestAMQSession.class);