Repository: activemq-artemis Updated Branches: refs/heads/ARTEMIS-780 df7b552ad -> b995501e9
fix checkstyle Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b995501e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b995501e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b995501e Branch: refs/heads/ARTEMIS-780 Commit: b995501e90c41f3d0e8546ae1880bb5e91ce1716 Parents: df7b552 Author: Martyn Taylor <[email protected]> Authored: Wed Nov 30 13:47:50 2016 +0000 Committer: Martyn Taylor <[email protected]> Committed: Wed Nov 30 13:47:50 2016 +0000 ---------------------------------------------------------------------- .../apache/activemq/artemis/rest/queue/QueueServiceManager.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b995501e/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/QueueServiceManager.java ---------------------------------------------------------------------- diff --git a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/QueueServiceManager.java b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/QueueServiceManager.java index f3efacb..170285a 100644 --- a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/QueueServiceManager.java +++ b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/QueueServiceManager.java @@ -22,7 +22,6 @@ import java.util.List; import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.client.ClientSession; import org.apache.activemq.artemis.core.server.RoutingType; -import org.apache.activemq.artemis.core.server.impl.AddressInfo; import org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions; import org.apache.activemq.artemis.rest.queue.push.FilePushStore; import org.apache.activemq.artemis.rest.queue.push.PushStore; @@ -88,8 +87,7 @@ public class QueueServiceManager extends DestinationServiceManager { if (!query.isExists()) { session.createAddress(SimpleString.toSimpleString(queueName), RoutingType.ANYCAST, true); session.createQueue(SimpleString.toSimpleString(queueName), RoutingType.ANYCAST, SimpleString.toSimpleString(queueName), queueDeployment.isDurableSend()); - } - else { + } else { ClientSession.QueueQuery qquery = session.queueQuery(SimpleString.toSimpleString(queueName)); if (!qquery.isExists()) { session.createQueue(SimpleString.toSimpleString(queueName), RoutingType.ANYCAST, SimpleString.toSimpleString(queueName), queueDeployment.isDurableSend());
