You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/08/28 09:57:24 UTC
svn commit: r1621084 -
/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org