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 2017/10/03 15:51:00 UTC

[jira] [Commented] (ARTEMIS-1352) Artemis 2.2.0, createTopic create an anycast queue when there is no consumer created

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

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

GitHub user clebertsuconic opened a pull request:

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

    ARTEMIS-1352 Fixing test on Auto created address

    

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

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

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

    https://github.com/apache/activemq-artemis/pull/1568.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 #1568
    
----
commit 9f5bc4c4781125b0c20c6f6e324d955a33d429ef
Author: Clebert Suconic <cl...@apache.org>
Date:   2017-10-03T15:48:00Z

    ARTEMIS-1352 Fixing test on Auto created address

----


> 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
>            Assignee: Justin Bertram
>             Fix For: 2.4.0
>
>
> 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)