You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2020/07/06 15:56:46 UTC
[activemq] branch master updated: no jira - add selector on
originalDestination attribute test
This is an automated email from the ASF dual-hosted git repository.
gtully pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/master by this push:
new b3386c8 no jira - add selector on originalDestination attribute test
b3386c8 is described below
commit b3386c8ac7c96b656438e74da5c24bc48f7fcfde
Author: gtully <ga...@gmail.com>
AuthorDate: Mon Jul 6 16:56:30 2020 +0100
no jira - add selector on originalDestination attribute test
---
.../test/java/org/apache/activemq/selector/SelectorTest.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/selector/SelectorTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/selector/SelectorTest.java
index 66a7af4..3ad8430 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/selector/SelectorTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/selector/SelectorTest.java
@@ -21,6 +21,7 @@ import javax.jms.JMSException;
import javax.jms.Message;
import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTextMessage;
import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.filter.BooleanExpression;
@@ -364,6 +365,15 @@ public class SelectorTest extends TestCase {
assertSelector(message, "REGEX('connection1111', REPLACE(JMSMessageID,':',''))", true);
}
+ public void testMatchOriginalDestinationAttribute() throws Exception {
+
+ ActiveMQMessage activeMQMessage = (ActiveMQMessage) createMessage();
+ ActiveMQQueue originalDest = new ActiveMQQueue("QQ");
+ activeMQMessage.setOriginalDestination(originalDest);
+ assertSelector(activeMQMessage, "JMSDestination='" + originalDest.getQualifiedName() +"'", true);
+ }
+
+
protected Message createMessage() throws JMSException {
Message message = createMessage("FOO.BAR");
message.setJMSType("selector-test");