diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/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/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) |