activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-1314) Using the message filter with JMSCorrelationID seems not to work
Date Fri, 06 Oct 2017 22:41:00 GMT

    [ https://issues.apache.org/jira/browse/ARTEMIS-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16195382#comment-16195382
] 

ASF subversion and git services commented on ARTEMIS-1314:
----------------------------------------------------------

Commit 6d94997aa8c9c0ed4d02ac9934eceee4161cdea0 in activemq-artemis's branch refs/heads/master
from [~tabish121]
[ https://git-wip-us.apache.org/repos/asf?p=activemq-artemis.git;h=6d94997 ]

ARTEMIS-1314 Fixing issues with JMS selectors on AMQP

Allows for JMS selectors on JMSCorrelationID as well as JMSXGroupID
and JMSXUserID along with some fixes to avoid an NPE case and fixes
to the conversion of AMQP MessageID and CorrelationID values when
doing cross protocol mappings.  Adds new tests to cover more cases
of using the JMS selector with Qpid JMS and the AMQP test client.


> Using the message filter with JMSCorrelationID seems not to work
> ----------------------------------------------------------------
>
>                 Key: ARTEMIS-1314
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-1314
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 2.1.0
>         Environment: * RHEL 7
> * Java 8
> * Qpid JMS 0.23.0
>            Reporter: Jens Reimann
>            Assignee: Timothy Bish
>             Fix For: 2.4.0
>
>
> Creating a consumer with a message filter for the JMS correlation ID seems not to work:
> {code:java}
> consumer = session.createConsumer(destination, "JMSCorrelationID='" + id + "'");
> {code}
> The message consumer never receives the message. However, removing the filter an manually
filtering does work:
> {code:java}
> if (id.equals(message.getJMSCorrelationID())) {
>   // do stuff
> }
> {code}
> Also does the correlation ID show up in the list of properties:
> {code}
> JMSType => null
> JMSMessageID => ID:d20ffaba-25f4-497a-80e9-99d58101f589:2:1:1-1
> JMSExpiration => 0
> JMSRedelivered => false
> JMSTimestamp => 1501572098651
> JMSXUserID => null
> JMSXGroupSeq => 0
> JMS_AMQP_ACK_TYPE => null
> JMSDeliveryMode => PERSISTENT
> JMSPriority => 4
> JMSReplyTo => null
> JMSXGroupID => null
> JMSDestination => serviceAExternal
> JMSXDeliveryCount => 1
> JMSCorrelationID => d1c2daf6-2f2a-4641-a917-0f211e53e110
> JMSDeliveryTime => 1501572098651
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message