diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-08-28 07:49:52 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-08-28 07:49:52 +0000 |
| commit | a8accc07864c8ef697b9a1c72f6a38e466bb9e5e (patch) | |
| tree | 1a39c39e3e510f449197ec3c1fe660820df20e2b | |
| parent | aa060edba99afab2437ec29a78ba0b73a6d4f4f3 (diff) | |
| download | qpid-python-a8accc07864c8ef697b9a1c72f6a38e466bb9e5e.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@1621083 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionFactoryImpl.java | 10 |
1 files changed, 9 insertions, 1 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 eb2bb370ef..0f53d00af1 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,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) |