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); }