Repository: qpid-jms Updated Branches: refs/heads/master b88ad6698 -> 41c040a89
Add tests for properties that require validation Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/41c040a8 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/41c040a8 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/41c040a8 Branch: refs/heads/master Commit: 41c040a8902576ce2762fcd008c5a287064b42ac Parents: b88ad66 Author: Timothy Bish <[email protected]> Authored: Fri Jan 23 12:34:46 2015 -0500 Committer: Timothy Bish <[email protected]> Committed: Fri Jan 23 12:34:46 2015 -0500 ---------------------------------------------------------------------- .../jms/transports/TransportOptionsTest.java | 54 ++++++++++++++++++++ 1 file changed, 54 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/41c040a8/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/TransportOptionsTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/TransportOptionsTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/TransportOptionsTest.java index ecc51e5..e7853ed 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/TransportOptionsTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/TransportOptionsTest.java @@ -17,6 +17,7 @@ package org.apache.qpid.jms.transports; import static org.junit.Assert.assertEquals; +import static org.junit.Assert.fail; import org.apache.qpid.jms.test.QpidJmsTestCase; import org.junit.Test; @@ -70,6 +71,59 @@ public class TransportOptionsTest extends QpidJmsTestCase { assertEquals(TEST_CONNECT_TIMEOUT, options.getConnectTimeout()); } + @Test + public void testSendBufferSizeValidation() { + TransportOptions options = createNonDefaultOptions().clone(); + try { + options.setSendBufferSize(0); + fail("Should have thrown an IllegalArgumentException"); + } catch (IllegalArgumentException expected) { + } + try { + options.setSendBufferSize(-1); + fail("Should have thrown an IllegalArgumentException"); + } catch (IllegalArgumentException expected) { + } + + options.setSendBufferSize(1); + } + + @Test + public void testReceiveBufferSizeValidation() { + TransportOptions options = createNonDefaultOptions().clone(); + try { + options.setReceiveBufferSize(0); + fail("Should have thrown an IllegalArgumentException"); + } catch (IllegalArgumentException expected) { + } + try { + options.setReceiveBufferSize(-1); + fail("Should have thrown an IllegalArgumentException"); + } catch (IllegalArgumentException expected) { + } + + options.setReceiveBufferSize(1); + } + + @Test + public void testTrafficClassValidation() { + TransportOptions options = createNonDefaultOptions().clone(); + try { + options.setTrafficClass(-1); + fail("Should have thrown an IllegalArgumentException"); + } catch (IllegalArgumentException expected) { + } + try { + options.setTrafficClass(256); + fail("Should have thrown an IllegalArgumentException"); + } catch (IllegalArgumentException expected) { + } + + options.setTrafficClass(0); + options.setTrafficClass(128); + options.setTrafficClass(255); + } + private TransportOptions createNonDefaultOptions() { TransportOptions options = new TransportOptions(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
