From 19adb89bf5e3e0661099bc2d9f46b17b7b4966f1 Mon Sep 17 00:00:00 2001 From: Alex Shvedoff Date: Wed, 29 Nov 2017 15:27:59 -0800 Subject: [PATCH] Add cleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose to RMQObjectFactory --- src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java b/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java index 00df72fd..5b4490a8 100644 --- a/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java +++ b/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java @@ -194,6 +194,7 @@ public Object createConnectionFactory(Reference ref, Hashtable environment f.setTerminationTimeout (getLongProperty (ref, environment, "terminationTimeout", true, f.getTerminationTimeout() )); f.setUsername (getStringProperty (ref, environment, "username", true, f.getUsername() )); f.setVirtualHost (getStringProperty (ref, environment, "virtualHost", true, f.getVirtualHost() )); + f.setCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose(getBooleanProperty(ref, environment, "cleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose", true, f.isCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose() )); return f; }