summaryrefslogtreecommitdiff
path: root/java/common/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'java/common/src/test')
-rw-r--r--java/common/src/test/java/org/apache/qpid/transport/ConnectionSettingsTest.java49
1 files changed, 49 insertions, 0 deletions
diff --git a/java/common/src/test/java/org/apache/qpid/transport/ConnectionSettingsTest.java b/java/common/src/test/java/org/apache/qpid/transport/ConnectionSettingsTest.java
new file mode 100644
index 0000000000..62ca0b70ba
--- /dev/null
+++ b/java/common/src/test/java/org/apache/qpid/transport/ConnectionSettingsTest.java
@@ -0,0 +1,49 @@
+package org.apache.qpid.transport;
+
+import org.apache.qpid.configuration.ClientProperties;
+import org.apache.qpid.test.utils.QpidTestCase;
+
+public class ConnectionSettingsTest extends QpidTestCase
+{
+ ConnectionSettings _conConnectionSettings;
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+ _conConnectionSettings = new ConnectionSettings();
+ }
+
+ public void testDefaultTCP_NODELAY()
+ {
+ assertTrue("Default for isTcpNodelay() should be true", _conConnectionSettings.isTcpNodelay());
+ }
+
+ public void testSystemPropertyOverrideTrueForTCP_NODELAY()
+ {
+ systemPropertyOverrideForTCP_NODELAYImpl(ClientProperties.QPID_TCP_NODELAY_PROP_NAME, true);
+ }
+
+ public void testSystemPropertyOverrideFalseForTCP_NODELAY()
+ {
+ systemPropertyOverrideForTCP_NODELAYImpl(ClientProperties.QPID_TCP_NODELAY_PROP_NAME, false);
+ }
+
+ public void testLegacySystemPropertyOverrideTrueForTCP_NODELAY()
+ {
+ systemPropertyOverrideForTCP_NODELAYImpl(ClientProperties.AMQJ_TCP_NODELAY_PROP_NAME, true);
+ }
+
+ public void testLegacySystemPropertyOverrideFalseForTCP_NODELAY()
+ {
+ systemPropertyOverrideForTCP_NODELAYImpl(ClientProperties.AMQJ_TCP_NODELAY_PROP_NAME, false);
+ }
+
+ private void systemPropertyOverrideForTCP_NODELAYImpl(String propertyName, boolean value)
+ {
+ //set the default via system property
+ setTestSystemProperty(propertyName, String.valueOf(value));
+
+ _conConnectionSettings = new ConnectionSettings();
+ assertEquals("Value for isTcpNodelay() is incorrect", value, _conConnectionSettings.isTcpNodelay());
+ }
+}