You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2016/11/23 17:43:22 UTC
[21/48] activemq-artemis git commit: Fix some failures in ProtonTest
Fix some failures in ProtonTest
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/4ccfc730
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/4ccfc730
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/4ccfc730
Branch: refs/heads/ARTEMIS-780
Commit: 4ccfc730b42a1a57900eb8a8645141acfacfe717
Parents: 6b441b7
Author: jbertram <jb...@apache.com>
Authored: Tue Nov 15 13:34:49 2016 -0600
Committer: jbertram <jb...@apache.com>
Committed: Wed Nov 23 09:04:34 2016 -0600
----------------------------------------------------------------------
.../activemq/artemis/tests/integration/amqp/ProtonTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/4ccfc730/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/ProtonTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/ProtonTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/ProtonTest.java
index d1f4546..b017c31 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/ProtonTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/ProtonTest.java
@@ -63,6 +63,7 @@ import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import org.apache.activemq.artemis.api.core.SimpleString;
+import org.apache.activemq.artemis.api.core.management.ResourceNames;
import org.apache.activemq.artemis.core.postoffice.Bindings;
import org.apache.activemq.artemis.core.remoting.CloseListener;
import org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnector;
@@ -775,6 +776,7 @@ public class ProtonTest extends ProtonTestBase {
Exception expectedException = null;
try {
session.createSender("AnAddressThatDoesNotExist");
+ fail("Creating a sender here on an address that doesn't exist should fail");
} catch (Exception e) {
expectedException = e;
}
@@ -896,7 +898,7 @@ public class ProtonTest extends ProtonTestBase {
//create request message for getQueueNames query
AmqpMessage request = new AmqpMessage();
- request.setApplicationProperty("_AMQ_ResourceName", "core.server");
+ request.setApplicationProperty("_AMQ_ResourceName", ResourceNames.BROKER);
request.setApplicationProperty("_AMQ_OperationName", "getQueueNames");
request.setReplyToAddress(destinationAddress);
request.setText("[]");