Repository: qpid-jms Updated Branches: refs/heads/master c7624e8ef -> d0dcc4a26
NO-JIRA Resolve warning in test code Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/d0dcc4a2 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/d0dcc4a2 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/d0dcc4a2 Branch: refs/heads/master Commit: d0dcc4a260dafdbd248616a5df00dde65ea70505 Parents: c7624e8 Author: Timothy Bish <[email protected]> Authored: Mon Mar 28 17:31:06 2016 -0400 Committer: Timothy Bish <[email protected]> Committed: Mon Mar 28 17:31:06 2016 -0400 ---------------------------------------------------------------------- .../org/apache/qpid/jms/failover/JmsOfflineBehaviorTests.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d0dcc4a2/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsOfflineBehaviorTests.java ---------------------------------------------------------------------- diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsOfflineBehaviorTests.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsOfflineBehaviorTests.java index 816fdc5..466561b 100644 --- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsOfflineBehaviorTests.java +++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsOfflineBehaviorTests.java @@ -133,11 +133,10 @@ public class JmsOfflineBehaviorTests extends AmqpTestSupport { startNewBroker(); URI brokerURI = new URI(getAmqpFailoverURI() + "failover.randomize=false"); - Connection connection = createAmqpConnection(brokerURI); + final JmsConnection connection = (JmsConnection) createAmqpConnection(brokerURI); connection.start(); - final JmsConnection jmsConnection = (JmsConnection) connection; - URI connectedURI = jmsConnection.getConnectedURI(); + URI connectedURI = connection.getConnectedURI(); assertNotNull(connectedURI); final List<URI> brokers = getBrokerURIs(); @@ -149,7 +148,7 @@ public class JmsOfflineBehaviorTests extends AmqpTestSupport { @Override public boolean isSatisified() throws Exception { - URI current = jmsConnection.getConnectedURI(); + URI current = connection.getConnectedURI(); if (current != null && current.equals(brokers.get(1))) { return true; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
