Repository: qpid-jms Updated Branches: refs/heads/master daba0801c -> 285f24e07
More coverage tests. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/d1dd6330 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/d1dd6330 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/d1dd6330 Branch: refs/heads/master Commit: d1dd6330f48df10c39e0742e5396c34af71615e2 Parents: daba080 Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Feb 10 11:11:55 2015 -0500 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Feb 10 11:11:55 2015 -0500 ---------------------------------------------------------------------- .../qpid/jms/provider/failover/FailoverProviderTest.java | 8 ++++++++ .../jms/provider/failover/FiloverProviderFactoryTest.java | 3 +++ 2 files changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d1dd6330/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverProviderTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverProviderTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverProviderTest.java index 917162a..3fece10 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverProviderTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverProviderTest.java @@ -74,6 +74,14 @@ public class FailoverProviderTest extends FailoverProviderTestSupport { } @Test(timeout = 30000) + public void testProviderListener() { + FailoverProvider provider = new FailoverProvider(uris, Collections.<String, String>emptyMap()); + assertNull(provider.getProviderListener()); + provider.setProviderListener(new DefaultProviderListener()); + assertNotNull(provider.getProviderListener()); + } + + @Test(timeout = 30000) public void testGetRemoteURI() throws Exception { final FailoverProvider provider = new FailoverProvider(uris, Collections.<String, String>emptyMap()); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d1dd6330/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FiloverProviderFactoryTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FiloverProviderFactoryTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FiloverProviderFactoryTest.java index d2db7c2..97736d8 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FiloverProviderFactoryTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FiloverProviderFactoryTest.java @@ -65,6 +65,7 @@ public class FiloverProviderFactoryTest { assertEquals(FailoverProvider.DEFAULT_MAX_RECONNECT_ATTEMPTS, failover.getMaxReconnectAttempts()); assertEquals(FailoverProvider.DEFAULT_USE_RECONNECT_BACKOFF, failover.isUseReconnectBackOff()); assertEquals(FailoverProvider.DEFAULT_RECONNECT_BACKOFF_MULTIPLIER, failover.getReconnectBackOffMultiplier(), 0.0); + assertEquals(FailoverProvider.DEFAULT_WARN_AFTER_RECONNECT_ATTEMPTS, failover.getWarnAfterReconnectAttempts()); assertEquals(FailoverUriPool.DEFAULT_RANDOMIZE_ENABLED, failover.isRandomize()); } @@ -82,6 +83,7 @@ public class FiloverProviderFactoryTest { "&failover.maxReconnectDelay=" + (FailoverProvider.DEFAULT_MAX_RECONNECT_DELAY + 3) + "&failover.startupMaxReconnectAttempts=" + (FailoverProvider.DEFAULT_STARTUP_MAX_RECONNECT_ATTEMPTS + 4) + "&failover.maxReconnectAttempts=" + (FailoverProvider.DEFAULT_MAX_RECONNECT_ATTEMPTS + 5) + + "&failover.warnAfterReconnectAttempts=" + (FailoverProvider.DEFAULT_WARN_AFTER_RECONNECT_ATTEMPTS + 6) + "&failover.useReconnectBackOff=" + (!FailoverProvider.DEFAULT_USE_RECONNECT_BACKOFF) + "&failover.reconnectBackOffMultiplier=" + (FailoverProvider.DEFAULT_RECONNECT_BACKOFF_MULTIPLIER + 1.0d) + "&failover.randomize=" + (!FailoverUriPool.DEFAULT_RANDOMIZE_ENABLED)); @@ -97,6 +99,7 @@ public class FiloverProviderFactoryTest { assertEquals(FailoverProvider.DEFAULT_MAX_RECONNECT_DELAY + 3, failover.getMaxReconnectDelay()); assertEquals(FailoverProvider.DEFAULT_STARTUP_MAX_RECONNECT_ATTEMPTS + 4, failover.getStartupMaxReconnectAttempts()); assertEquals(FailoverProvider.DEFAULT_MAX_RECONNECT_ATTEMPTS + 5, failover.getMaxReconnectAttempts()); + assertEquals(FailoverProvider.DEFAULT_WARN_AFTER_RECONNECT_ATTEMPTS + 6, failover.getWarnAfterReconnectAttempts()); assertEquals(!FailoverProvider.DEFAULT_USE_RECONNECT_BACKOFF, failover.isUseReconnectBackOff()); assertEquals(FailoverProvider.DEFAULT_RECONNECT_BACKOFF_MULTIPLIER + 1.0d, failover.getReconnectBackOffMultiplier(), 0.0); assertEquals(!FailoverUriPool.DEFAULT_RANDOMIZE_ENABLED, failover.isRandomize()); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
