Author: rgodfrey
Date: Thu Aug 28 07:28:52 2014
New Revision: 1621076
URL: http://svn.apache.org/r1621076
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=1621076&r1=1621075&r2=1621076&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:28:52 2014
@@ -138,10 +138,6 @@ public class ConnectionFactoryImpl imple
_remoteHost = remoteHost;
_ssl = ssl;
_maxSessions = maxSessions;
- if(! "".equals(System.getProperty("qpid.sync_publish","")))
- {
- _syncPublish = Boolean.getBoolean("qpid.sync_publish");
- }
}
public ConnectionImpl createConnection() throws JMSException
@@ -243,7 +239,7 @@ public class ConnectionFactoryImpl imple
String remoteHost;
boolean binaryMessageId = true;
- Boolean syncPublish;
+ Boolean syncPublish = Boolean.getBoolean("qpid.sync_publish");
int maxSessions;
public boolean ssl;
public int maxPrefetch;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
