You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2011/07/01 23:23:48 UTC
svn commit: r1142097 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java
Author: tabish
Date: Fri Jul 1 21:23:48 2011
New Revision: 1142097
URL: http://svn.apache.org/viewvc?rev=1142097&view=rev
Log:
Add test case for: https://issues.apache.org/jira/browse/AMQ-2528
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java?rev=1142097&r1=1142096&r2=1142097&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java Fri Jul 1 21:23:48 2011
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- *
+ *
*/
public class JmsTopicSelectorTest extends TestSupport {
private static final Logger LOG = LoggerFactory.getLogger(JmsTopicSelectorTest.class);
@@ -143,6 +143,24 @@ public class JmsTopicSelectorTest extend
}
+ public void testEmptyPropertySelector() throws Exception {
+ int remaining = 5;
+ Message message = null;
+ consumer = createConsumer("");
+ sendMessages();
+ while (true) {
+ message = consumer.receive(1000);
+ if (message == null) {
+ break;
+ }
+
+ remaining--;
+ }
+ assertEquals(remaining, 0);
+ consumer.close();
+ consumeMessages(remaining);
+ }
+
public void testPropertySelector() throws Exception {
int remaining = 5;
Message message = null;