[activemq-artemis] branch master updated: NO-JIRA Adding Queue Delete Delay on openWireTestsuite

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[activemq-artemis] branch master updated: NO-JIRA Adding Queue Delete Delay on openWireTestsuite

clebertsuconic-2
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 3fff744  NO-JIRA Adding Queue Delete Delay on openWireTestsuite
3fff744 is described below

commit 3fff744de4d0ba3b209c821cc1404d920455157c
Author: Clebert Suconic <[hidden email]>
AuthorDate: Fri Jan 10 10:46:25 2020 -0500

    NO-JIRA Adding Queue Delete Delay on openWireTestsuite
   
    Some open wire tests will close a consumer and open it right away.
   
    The removal of the queue is asynchronous, having this kind of behaviour may lead to issues
    after we moved the QueueManager to be asynchronous.
---
 .../org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
index 91498b8..22a8e44 100644
--- a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
+++ b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
@@ -93,6 +93,7 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase {
       commonSettings.setExpiryAddress(dla);
       commonSettings.setAutoCreateQueues(true);
       commonSettings.setAutoCreateAddresses(true);
+      commonSettings.setAutoDeleteQueuesDelay(10_0000);
 
       if (bservice.extraConnectors.size() == 0) {
          serverConfig.addAcceptorConfiguration("home", "tcp://localhost:61616");