diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-12-07 19:33:05 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-12-07 19:33:05 +0000 |
| commit | 8101025f10d83a548d0e4d52fa58ed8604c281ef (patch) | |
| tree | 2f8d5ee09572d63a879ffeae15d649bc17189382 /java/client | |
| parent | 2f149e005175b204dd283f89af5e05e0a44d87c7 (diff) | |
| download | qpid-python-8101025f10d83a548d0e4d52fa58ed8604c281ef.tar.gz | |
QPID-3659 Added a method in AMQBrokerDetails to handle boolean
properties which defaults to "True". I also added a log message to
printout the TCP_NODELAY value returned by the sockets getTcpNoDelay()
method as a way of figuring out the exact settings.
(cherry picked from commit d2377ceb08af030e95ccc3d578df2d59ca3933c1)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1211611 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java | 28 |
1 files changed, 21 insertions, 7 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java b/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java index c0d4d8a893..d6589bacdf 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java @@ -264,12 +264,26 @@ public class AMQBrokerDetails implements BrokerDetails public boolean getBooleanProperty(String propName) { - if (_options.containsKey(propName)) - { - return Boolean.parseBoolean(_options.get(propName)); - } - - return false; + return getBooleanProperty(propName, false); + } + + public boolean getBooleanProperty(String propName, boolean defaultValue) + { + if (_options.containsKey(propName)) + { + if (defaultValue) + { + return !_options.get(propName).equalsIgnoreCase("false"); + } + else + { + return Boolean.parseBoolean(_options.get(propName)); + } + } + else + { + return defaultValue; + } } public void setTimeout(long timeout) @@ -439,7 +453,7 @@ public class AMQBrokerDetails implements BrokerDetails if (getProperty(BrokerDetails.OPTIONS_TCP_NO_DELAY) != null) { conSettings.setTcpNodelay( - getBooleanProperty(BrokerDetails.OPTIONS_TCP_NO_DELAY)); + getBooleanProperty(BrokerDetails.OPTIONS_TCP_NO_DELAY,true)); } return conSettings; |
