You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2023/06/06 22:21:00 UTC

[jira] [Work logged] (ARTEMIS-4259) JMS consumer + FQQN + selector not working

     [ https://issues.apache.org/jira/browse/ARTEMIS-4259?focusedWorklogId=864009&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-864009 ]

ASF GitHub Bot logged work on ARTEMIS-4259:
-------------------------------------------

                Author: ASF GitHub Bot
            Created on: 06/Jun/23 22:20
            Start Date: 06/Jun/23 22:20
    Worklog Time Spent: 10m 
      Work Description: clebertsuconic opened a new pull request, #4502:
URL: https://github.com/apache/activemq-artemis/pull/4502

   co-authored with Justin Bertram




Issue Time Tracking
-------------------

    Worklog Id:     (was: 864009)
    Time Spent: 1h 20m  (was: 1h 10m)

> JMS consumer + FQQN + selector 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
>          Time Spent: 1h 20m
>  Remaining Estimate: 0h
>
> 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)