Author: marnie
Date: Tue Nov 7 00:57:46 2006
New Revision: 472039
URL: http://svn.apache.org/viewvc?view=rev&rev=472039
Log:
Added tests for QueueReceiver create methods to check for ClassCastException
etc.
Modified:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
Modified:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java?view=diff&rev=472039&r1=472038&r2=472039
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
Tue Nov 7 00:57:46 2006
@@ -27,6 +27,7 @@
import javax.jms.JMSException;
import javax.jms.TopicSubscriber;
+import javax.jms.QueueReceiver;
import junit.framework.JUnit4TestAdapter;
@@ -60,11 +61,29 @@
@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()
