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 2018/10/23 13:32:00 UTC

[jira] [Commented] (ARTEMIS-2031) Message Filter not displayed in management console for ANYCAST Queues

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

Justin Bertram commented on ARTEMIS-2031:
-----------------------------------------

To clarify, this is not a bug because this screen in the admin console is showing the queues themselves, not the consumers.  In the case of a consumer on an anycast queue the filter is applied at the consumer. The filter is not defined on the queue. This is so multiple consumers can connect to the queue with different filters/selectors. However, in the case of a consumer on a multicast queue the filter is actually part of the queue itself so that only matching messages sent to the corresponding address are placed in the queue.

> Message Filter not displayed in management console for ANYCAST Queues
> ---------------------------------------------------------------------
>
>                 Key: ARTEMIS-2031
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-2031
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>          Components: Broker, Web Console
>    Affects Versions: 2.6.3
>            Reporter: Johan Stenberg
>            Priority: Minor
>         Attachments: AdminUI_Queues.png
>
>
> The Admin UI only shows the message filter for multicast but not for unicast addresses.
> To reproduce, create a new broker instance and try the following code:
> {code:java}
> import java.util.concurrent.TimeUnit;
> import javax.jms.*;
> import org.apache.qpid.jms.*;
> /*
>  <dependency>
>     <groupId>org.apache.qpid</groupId>
>     <artifactId>qpid-jms-client</artifactId>
>     <version>0.35.0</version>
>  </dependency>
>  */
> public class Test {
>    public static void main(final String[] args) throws Exception {
>       final JmsQueue queue = new JmsQueue("myQueueWithFilter");
>       final JmsTopic topic = new JmsTopic("myTopicWithFilter");
>       try ( //
>             final Connection conn = new JmsConnectionFactory("amqp://localhost").createConnection("user", "user"); //
>             final Session sess = conn.createSession(); //
>             final MessageConsumer queueConsumer = sess.createConsumer(queue, "type='FOO'"); //
>             final MessageConsumer topicConsumer = sess.createConsumer(topic, "type='FOO'"); //
>       ) {
>          conn.start();
>          Thread.sleep(TimeUnit.SECONDS.toMillis(60));
>       }
>    }
> }
> {code}
> The admin UI then shows both addresses but only for the MULTICAST queue it displays the message filter.
>  
> !AdminUI_Queues.png!
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)