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 <[email protected]> Authored: Tue Nov 15 13:34:49 2016 -0600 Committer: jbertram <[email protected]> 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("[]");
