From a715cbe868e3834edb13c7baf3b98546c15a219e Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Thu, 22 Jul 2010 14:22:01 +0000 Subject: Cleanup M2.x merge code git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@966681 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/client/transport/TransportConnection.java | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) (limited to 'qpid/java/client/src/main') 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 { -- cgit v1.2.1