Author: rgodfrey
Date: Thu Aug 28 07:57:23 2014
New Revision: 1621084
URL: http://svn.apache.org/r1621084
Log:
QPID-6050 : [JMS AMQP 1.0 client] Allow system property for sync publish to be
overridden at the connection level to restore "default" behaviour at the
connection
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java?rev=1621084&r1=1621083&r2=1621084&view=diff
==============================================================================
---
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
(original)
+++
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
Thu Aug 28 07:57:23 2014
@@ -330,7 +330,14 @@ public class ConnectionFactoryImpl imple
{
public void setOption(ConnectionOptions options, String value)
{
- options.syncPublish = Boolean.parseBoolean(value);
+ if("".equals(value) || "default".equals(value))
+ {
+ options.syncPublish = null;
+ }
+ else
+ {
+ options.syncPublish = Boolean.parseBoolean(value);
+ }
}
},
new OptionSetter("max-sessions", "set maximum number of sessions
allowed")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
