From c904951e1e871046eb2a8496c72de86214161886 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 28 Aug 2014 07:49: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@1621083 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) (limited to 'qpid/java') diff --git a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java index eb2bb370ef..0f53d00af1 100644 --- a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java +++ b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java @@ -138,6 +138,10 @@ public class ConnectionFactoryImpl implements ConnectionFactory, TopicConnection _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 implements ConnectionFactory, TopicConnection int port = url.getPort(); final ConnectionOptions options = new ConnectionOptions(); - if (port == -1) { if ("amqps".equals(protocol)) @@ -438,6 +441,11 @@ public class ConnectionFactoryImpl implements ConnectionFactory, TopicConnection } } + if(System.getProperties().containsKey("qpid.sync_publish")) + { + options.syncPublish = Boolean.getBoolean("qpid.sync_publish"); + } + OptionSetter.parseOptions(url, options); if (options.remoteHost == null) -- cgit v1.2.1