diff options
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java index a4f8bb0166..8e4b59910c 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java @@ -52,7 +52,7 @@ public class TransportConnection { private static ITransportConnection _instance; - private static Map _inVmPipeAddress = new HashMap(); + private static final Map _inVmPipeAddress = new HashMap(); private static VmPipeAcceptor _acceptor; private static int _currentInstance = -1; private static int _currentVMPort = -1; @@ -177,16 +177,8 @@ public class TransportConnection { if (AutoCreate) { - if (AutoCreate) - { - _logger.warn("Auto Creating InVM Broker on port:" + port); - createVMBroker(port); - } - else - { - throw new AMQVMBrokerCreationException(null, port, "VM Broker on port " + port - + " does not exist. Auto create disabled.", null); - } + _logger.warn("Auto Creating InVM Broker on port:" + port); + createVMBroker(port); } else { |