You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Justin Bertram (Jira)" <ji...@apache.org> on 2023/04/25 21:45:00 UTC
[jira] [Updated] (ARTEMIS-4259) JMS topic + FQQN + filter not working
[ https://issues.apache.org/jira/browse/ARTEMIS-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Justin Bertram updated ARTEMIS-4259:
------------------------------------
Description:
The CORE protocol does not honor consumers with a filter when used on FQQN topics.
Steps to reproduce:
Start a consumer using CLI:
{noformat}
./artemis consumer --url tcp://localhost:61616 --destination topic://topic1::topic1.queue1 --protocol=core --message-count 1 --filter "foo='bar'" --verbose{noformat}
Send a message without the filter string:
{noformat}
./artemis producer --url tcp://localhost:61616 --destination topic://topic1::topic1.queue1 --protocol=core --message-count 1 --message "some text"{noformat}
You can observe the CORE client consuming the message which does not contain the filter String:
{noformat}
Connection brokerURL = tcp://localhost:61616
Consumer:: filter = foo='bar'
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 wait until 1 messages are consumed
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Received some text
JMS Message ID:ID:a00cbea3-dda7-11ed-9c2d-b42e99ea6f5c
Received text sized at 9
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Consumed: 1 messages
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Elapsed time in second : 8 s
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Elapsed time in milli second : 8140 milli seconds
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Consumed: 1 messages
Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Consumer thread finished{noformat}
> JMS topic + FQQN + filter not working
> -------------------------------------
>
> Key: ARTEMIS-4259
> URL: https://issues.apache.org/jira/browse/ARTEMIS-4259
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Reporter: Justin Bertram
> Assignee: Justin Bertram
> Priority: Major
>
> The CORE protocol does not honor consumers with a filter when used on FQQN topics.
> Steps to reproduce:
> Start a consumer using CLI:
> {noformat}
> ./artemis consumer --url tcp://localhost:61616 --destination topic://topic1::topic1.queue1 --protocol=core --message-count 1 --filter "foo='bar'" --verbose{noformat}
> Send a message without the filter string:
> {noformat}
> ./artemis producer --url tcp://localhost:61616 --destination topic://topic1::topic1.queue1 --protocol=core --message-count 1 --message "some text"{noformat}
> You can observe the CORE client consuming the message which does not contain the filter String:
> {noformat}
> Connection brokerURL = tcp://localhost:61616
> Consumer:: filter = foo='bar'
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 wait until 1 messages are consumed
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Received some text
> JMS Message ID:ID:a00cbea3-dda7-11ed-9c2d-b42e99ea6f5c
> Received text sized at 9
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Consumed: 1 messages
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Elapsed time in second : 8 s
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Elapsed time in milli second : 8140 milli seconds
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Consumed: 1 messages
> Consumer ActiveMQTopic[topic1::topic1.queue1], thread=0 Consumer thread finished{noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)