Repository: qpid-jms Updated Branches: refs/heads/master 022fb1591 -> f111d9dd3
rename method to use the correct performative name Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/ccc39ef2 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/ccc39ef2 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/ccc39ef2 Branch: refs/heads/master Commit: ccc39ef2fa92f4dd44dc9833ae1e4fa78584d9e7 Parents: 022fb15 Author: Robert Gemmell <[email protected]> Authored: Thu Feb 26 10:53:41 2015 +0000 Committer: Robert Gemmell <[email protected]> Committed: Thu Feb 26 10:53:41 2015 +0000 ---------------------------------------------------------------------- .../apache/qpid/jms/integration/ConnectionIntegrationTest.java | 4 ++-- .../java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/ccc39ef2/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java index 4db603e..6d7a72c 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java @@ -106,7 +106,7 @@ public class ConnectionIntegrationTest extends QpidJmsTestCase { Connection connection = testFixture.establishConnecton(testPeer, null, null, null, false); // Tell the test peer to close the connection when executing its last handler - testPeer.remotelyEndConnection(true); + testPeer.remotelyCloseConnection(true); //Add the exception listener connection.setExceptionListener(new ExceptionListener() { @@ -137,7 +137,7 @@ public class ConnectionIntegrationTest extends QpidJmsTestCase { // Create a consumer, then remotely end the connection afterwards. testPeer.expectReceiverAttach(); testPeer.expectLinkFlow(); - testPeer.remotelyEndConnection(true); + testPeer.remotelyCloseConnection(true); Queue queue = session.createQueue("myQueue"); MessageConsumer consumer = session.createConsumer(queue); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/ccc39ef2/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java index 1e46bc2..d25688d 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java @@ -1110,7 +1110,7 @@ public class TestAmqpPeer implements AutoCloseable } } - public void remotelyEndConnection(boolean expectCloseResponse) { + public void remotelyCloseConnection(boolean expectCloseResponse) { synchronized (_handlersLock) { // Prepare a composite to insert this action at the end of the handler sequence CompositeAmqpPeerRunnable comp = insertCompsiteActionForLastHandler(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
