activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-1352) Artemis 2.2.0, createTopic create an anycast queue when there is no consumer created
Date Wed, 27 Sep 2017 17:06:01 GMT

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

ASF GitHub Bot commented on ARTEMIS-1352:
-----------------------------------------

GitHub user jbertram opened a pull request:

    https://github.com/apache/activemq-artemis/pull/1558

    ARTEMIS-1352 auto-create MULTICAST queue when AMQP client sends to topic

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/jbertram/activemq-artemis ARTEMIS-1352

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/activemq-artemis/pull/1558.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #1558
    
----
commit e041bd29c0696b2cac7f07a331f4e8806f934764
Author: Justin Bertram <jbertram@apache.org>
Date:   2017-09-06T14:07:21Z

    ARTEMIS-1352 auto-create MULTICAST queue when AMQP client sends to topic

----


> Artemis 2.2.0, createTopic create an anycast queue when there is no consumer created
> ------------------------------------------------------------------------------------
>
>                 Key: ARTEMIS-1352
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-1352
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>    Affects Versions: 2.2.0
>            Reporter: vina chen
>
> I have downloaded the latest Artemis 2.2.0 and testing it with Qpid AMQP client 0.23.0
and sending message through a Topic. Here is my config in broker.xml (Basically, it is default
from the box): 
> <security-settings>
>          <security-setting match="#">
>             <permission type="createNonDurableQueue" roles="amq"/>
>             <permission type="deleteNonDurableQueue" roles="amq"/>
>             <permission type="createDurableQueue" roles="amq"/>
>             <permission type="deleteDurableQueue" roles="amq"/>
>             <permission type="createAddress" roles="amq"/>
>             <permission type="deleteAddress" roles="amq"/>
>             <permission type="consume" roles="amq"/>
>             <permission type="browse" roles="amq"/>
>             <permission type="send" roles="amq"/>
>             <permission type="manage" roles="amq"/>
>          </security-setting>
>       </security-settings>
> <address-setting match="#">
>             <dead-letter-address>DLQ</dead-letter-address>
>             <expiry-address>ExpiryQueue</expiry-address>
>             <redelivery-delay>0</redelivery-delay>
>             
>             <max-size-bytes>-1</max-size-bytes>
>             <message-counter-history-day-limit>10</message-counter-history-day-limit>
>             <address-full-policy>PAGE</address-full-policy>
>             <auto-create-queues>true</auto-create-queues>
>             <auto-create-addresses>true</auto-create-addresses>
>             <auto-create-jms-queues>true</auto-create-jms-queues>
>             <auto-create-jms-topics>true</auto-create-jms-topics>
>          </address-setting>
> Here is my sender side code: 
> String connectionUrl = "amqp://localhost:5672"; 
> ConnectionFactory connectionFactory = new JmsConnectionFactory(connectionUrl); 
> connection = connectionFactory.createConnection(); 
> session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
> Topic topicQueue = session.createTopic("SpyTopic9"); 
> MessageProducer topicSender = session.createProducer(topicQueue); 
> and receiver side: 
> Topic topicQueue = session.createTopic("SpyTopic9"); 
> MessageConsumer topicConsumer = session.createConsumer(topicQueue); 
> my sender and receiver code is a 2 separate program which located on 2 different machine.
I noticed that if I start sender side program first without receiver side code running, the
artemis created a anycast instead of multicast. And if at this time, I start the receiver
side, it shows me the following message : 
>  Exception:Address SpyTopic9 is not configured for topic support [condition = amqp:illegal-state]

> And if I started receiver first and then start sender, then everything looks fine.  
> I wonder if the topic should be created as a multicast when auto-created address is configured.
Thanks.



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

Mime
View raw message