summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-08-28 07:28:52 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-08-28 07:28:52 +0000
commitaa060edba99afab2437ec29a78ba0b73a6d4f4f3 (patch)
tree3ec46c6e6fac6e2516f60dfea343a569fc4a2f32 /java
parent63f4cf9643c9bfeb627a09871a1894d0c23f2b12 (diff)
downloadqpid-python-aa060edba99afab2437ec29a78ba0b73a6d4f4f3.tar.gz
QPID-6050 : [JMS AMQP 1.0 client] Setting system property qpid.sync_publish does not have the intended effect
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1621076 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java6
1 files changed, 1 insertions, 5 deletions
diff --git a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
index e83fc24fcd..eb2bb370ef 100644
--- a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
+++ b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java
@@ -138,10 +138,6 @@ public class ConnectionFactoryImpl implements ConnectionFactory, TopicConnection
_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 implements ConnectionFactory, TopicConnection
String remoteHost;
boolean binaryMessageId = true;
- Boolean syncPublish;
+ Boolean syncPublish = Boolean.getBoolean("qpid.sync_publish");
int maxSessions;
public boolean ssl;
public int maxPrefetch;