Author: rgodfrey
Date: Thu Aug 28 07:49:52 2014
New Revision: 1621083
URL: http://svn.apache.org/r1621083
Log:
QPID-6050 : [JMS AMQP 1.0 client] Setting system property qpid.sync_publish
does not have the intended effect
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=1621083&r1=1621082&r2=1621083&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:49:52 2014
@@ -138,6 +138,10 @@ public class ConnectionFactoryImpl imple
_remoteHost = remoteHost;
_ssl = ssl;
_maxSessions = maxSessions;
+ if(System.getProperties().containsKey("qpid.sync_publish"))
+ {
+ _syncPublish = Boolean.getBoolean("qpid.sync_publish");
+ }
}
public ConnectionImpl createConnection() throws JMSException
@@ -399,7 +403,6 @@ public class ConnectionFactoryImpl imple
int port = url.getPort();
final ConnectionOptions options = new ConnectionOptions();
-
if (port == -1)
{
if ("amqps".equals(protocol))
@@ -438,6 +441,11 @@ public class ConnectionFactoryImpl imple
}
}
+ if(System.getProperties().containsKey("qpid.sync_publish"))
+ {
+ options.syncPublish = Boolean.getBoolean("qpid.sync_publish");
+ }
+
OptionSetter.parseOptions(url, options);
if (options.remoteHost == null)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
