From aa060edba99afab2437ec29a78ba0b73a6d4f4f3 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 28 Aug 2014 07:28:52 +0000 Subject: 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 --- .../org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) (limited to 'java') 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; -- cgit v1.2.1