Repository: qpid-jms Updated Branches: refs/heads/master a3ae2856c -> 6217cb29a
Ensure connection is closed so its threads are shutdown if any. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b172d59b Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b172d59b Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b172d59b Branch: refs/heads/master Commit: b172d59ba73675ea8b8f6a170f36a8150b1c4d09 Parents: a3ae285 Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Jan 13 16:43:09 2015 -0500 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Jan 13 16:43:09 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/qpid/jms/JmsConnectionTest.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b172d59b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTest.java index 4f50a37..f3d8a57 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTest.java @@ -130,10 +130,24 @@ public class JmsConnectionTest { } }).when(provider).create(Mockito.any(JmsResource.class), Mockito.any(ProviderFuture.class)); + Mockito.doAnswer(new Answer<Object>() { + @Override + public Object answer(InvocationOnMock invocation) throws Throwable { + Object[] args = invocation.getArguments(); + LOG.debug("Handling provider destroy call"); + if (args[0] instanceof JmsConnectionInfo) { + ProviderFuture request = (ProviderFuture) args[1]; + request.onSuccess(); + } + return null; + } + }).when(provider).destroy(Mockito.any(JmsResource.class), Mockito.any(ProviderFuture.class)); + JmsConnection connection = new JmsConnection("ID:TEST:1", provider, clientIdGenerator); assertFalse(connection.isConnected()); connection.start(); assertTrue(connection.isConnected()); + connection.close(); } //---------- Test methods fail after connection closed -------------------// --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
