You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2008/09/23 15:20:57 UTC
svn commit: r698175 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java
Author: chirino
Date: Tue Sep 23 06:20:57 2008
New Revision: 698175
URL: http://svn.apache.org/viewvc?rev=698175&view=rev
Log:
adding test case for https://issues.apache.org/activemq/browse/AMQ-1949
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java?rev=698175&r1=698174&r2=698175&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java Tue Sep 23 06:20:57 2008
@@ -598,4 +598,29 @@
assertNull(consumer.receiveNoWait());
}
+
+ public void testDupsOkConsumer() throws Exception {
+
+ // Receive a message with the JMS API
+ connection.start();
+ Session session = connection.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
+ destination = createDestination(session, ActiveMQDestination.QUEUE_TYPE);
+ MessageConsumer consumer = session.createConsumer(destination);
+
+ // Send the messages
+ sendMessages(session, destination, 4);
+
+ // Make sure only 4 message are delivered.
+ for( int i=0; i < 4; i++){
+ Message m = consumer.receive(1000);
+ assertNotNull(m);
+ }
+ assertNull(consumer.receive(1000));
+
+ // Close out the consumer.. no other messages should be left on the queue.
+ consumer.close();
+
+ consumer = session.createConsumer(destination);
+ assertNull(consumer.receive(1000));
+ }
}