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-1490) Race on deleteAddress when autocreated
Date Tue, 31 Oct 2017 13:10:00 GMT

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

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

Github user clebertsuconic commented on a diff in the pull request:

    https://github.com/apache/activemq-artemis/pull/1625#discussion_r147988933
  
    --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ConsumerTest.java
---
    @@ -261,6 +261,42 @@ public void testAutoCreateMulticastAddress() throws Throwable {
        }
     
        @Test
    +   public void testAutoCreateCOnConsumer() throws Throwable {
    +
    +      final SimpleString thisQueue = SimpleString.toSimpleString("ThisQueue");
    +      if (!isNetty()) {
    +         // no need to run the test, there's no AMQP support
    +         return;
    +      }
    +
    +      for (int i = 0; i < 10; i++) {
    +         ConnectionFactory factorySend = createFactory(2);
    +         Connection connection = factorySend.createConnection();
    +
    +         try {
    +            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    +            javax.jms.Queue queue = session.createQueue(thisQueue.toString());
    +            MessageProducer producer = session.createProducer(queue);
    +
    +            MessageConsumer consumer = session.createConsumer(queue);
    +            connection.start();
    +
    +            producer.send(session.createTextMessage("hello"));
    +
    +            Assert.assertNotNull(consumer.receive(5000));
    +            consumer.close();
    +            session.close();
    +         } finally {
    +            connection.close();
    +         }
    +
    +         Wait.waitFor(() -> server.getAddressInfo(thisQueue) == null, 1000, 10);
    --- End diff --
    
    @mtaylor without that change, this will always fail on this loop (at least on my laptop).


> Race on deleteAddress when autocreated
> --------------------------------------
>
>                 Key: ARTEMIS-1490
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-1490
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>    Affects Versions: 2.3.0
>            Reporter: clebert suconic
>            Assignee: clebert suconic
>             Fix For: 2.4.0
>
>




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

Mime
View raw message