activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [2/3] activemq-artemis git commit: Fix QueueCommandTest
Date Fri, 09 Dec 2016 03:15:37 GMT
Fix QueueCommandTest


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

Branch: refs/heads/ARTEMIS-780
Commit: 3f2a0afeef42bd92bfc67441d2d421dcd5d302fd
Parents: a8b42b0
Author: jbertram <jbertram@apache.com>
Authored: Thu Dec 8 21:08:01 2016 -0600
Committer: jbertram <jbertram@apache.com>
Committed: Thu Dec 8 21:08:01 2016 -0600

----------------------------------------------------------------------
 .../activemq/artemis/core/server/impl/ActiveMQServerImpl.java      | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3f2a0afe/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
index e962aa0..ed8c3d8 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
@@ -2519,6 +2519,8 @@ public class ActiveMQServerImpl implements ActiveMQServer {
             createOrUpdateAddressInfo(defaultAddressInfo.setAutoCreated(true));
             addressAlreadyExists = false;
          }
+      } else if (info == null) {
+         throw ActiveMQMessageBundle.BUNDLE.addressDoesNotExist(addressName);
       }
 
       final QueueConfig queueConfig = queueConfigBuilder.filter(filter).pagingManager(pagingManager).user(user).durable(durable).temporary(temporary).autoCreated(autoCreated).routingType(routingType).maxConsumers(maxConsumers).deleteOnNoConsumers(deleteOnNoConsumers).build();


Mime
View raw message