You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2017/04/17 09:49:19 UTC
svn commit: r1791671 -
/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/ProtocolEngine_1_0_0Test.java
Author: lquack
Date: Mon Apr 17 09:49:19 2017
New Revision: 1791671
URL: http://svn.apache.org/viewvc?rev=1791671&view=rev
Log:
QPID-7741: [Java Broker] fix test
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/ProtocolEngine_1_0_0Test.java
Modified: qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/ProtocolEngine_1_0_0Test.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/ProtocolEngine_1_0_0Test.java?rev=1791671&r1=1791670&r2=1791671&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/ProtocolEngine_1_0_0Test.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/ProtocolEngine_1_0_0Test.java Mon Apr 17 09:49:19 2017
@@ -209,6 +209,7 @@ public class ProtocolEngine_1_0_0Test ex
.getHeaderIdentifier()));
Open open = new Open();
+ open.setContainerId("testContainerId");
_frameWriter.send(AMQFrame.createAMQFrame((short)0,open));
verify(_virtualHost).registerConnection(any(AMQPConnection.class));
@@ -227,6 +228,7 @@ public class ProtocolEngine_1_0_0Test ex
_protocolEngine_1_0_0.received(QpidByteBuffer.wrap(ProtocolEngineCreator_1_0_0.getInstance().getHeaderIdentifier()));
Open open = new Open();
+ open.setContainerId("testContainerId");
_frameWriter.send(AMQFrame.createAMQFrame((short)0,open));
verify(_virtualHost, never()).registerConnection(any(AMQPConnection.class));
@@ -252,6 +254,7 @@ public class ProtocolEngine_1_0_0Test ex
_protocolEngine_1_0_0.received(QpidByteBuffer.wrap(ProtocolEngineCreator_1_0_0.getInstance().getHeaderIdentifier()));
Open open = new Open();
+ open.setContainerId("testContainerId");
_frameWriter.send(AMQFrame.createAMQFrame((short)0,open));
verify(_virtualHost).registerConnection(any(AMQPConnection.class));
@@ -281,6 +284,7 @@ public class ProtocolEngine_1_0_0Test ex
.getHeaderIdentifier()));
Open open = new Open();
+ open.setContainerId("testContainerId");
_frameWriter.send(AMQFrame.createAMQFrame((short)0,open));
verify(_virtualHost).registerConnection(any(AMQPConnection.class));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org