NO-JIRA ignore exception when deleting temp queue

Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b638748a
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b638748a
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b638748a

Branch: refs/heads/master
Commit: b638748ae366d613b1635a89df71c911ea704e61
Parents: e82b085
Author: Justin Bertram <jbert...@apache.org>
Authored: Tue Mar 6 11:29:24 2018 -0600
Committer: Clebert Suconic <clebertsuco...@apache.org>
Committed: Tue Mar 6 12:39:43 2018 -0500

----------------------------------------------------------------------
 .../artemis/core/server/impl/TransientQueueManagerImpl.java       | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b638748a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/TransientQueueManagerImpl.java
----------------------------------------------------------------------
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/TransientQueueManagerImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/TransientQueueManagerImpl.java
index ab14479..4985a7e 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/TransientQueueManagerImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/TransientQueueManagerImpl.java
@@ -17,6 +17,7 @@
 package org.apache.activemq.artemis.core.server.impl;
 
 import org.apache.activemq.artemis.api.core.ActiveMQException;
+import org.apache.activemq.artemis.api.core.ActiveMQNonExistentQueueException;
 import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
 import org.apache.activemq.artemis.core.server.ActiveMQServerLogger;
@@ -40,6 +41,8 @@ public class TransientQueueManagerImpl extends 
ReferenceCounterUtil implements T
 
          try {
             server.destroyQueue(queueName, null, false);
+         } catch (ActiveMQNonExistentQueueException e) {
+            // ignore
          } catch (ActiveMQException e) {
             
ActiveMQServerLogger.LOGGER.errorOnDeletingQueue(queueName.toString(), e);
          }

Reply via email to