QPID-2799: Convert address with underscores for temp queue name

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@985202 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 32 insertions, 21 deletions

diff --git a/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkDriver.java b/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkDriver.java
index ffe6c63d96..957a7190ee 100644
--- a/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkDriver.java
+++ b/qpid/java/common/src/test/java/org/apache/qpid/transport/TestNetworkDriver.java
@@ -39,29 +39,16 @@ import org.apache.qpid.ssl.SSLContextFactory;
 public class TestNetworkDriver implements NetworkDriver
 {
     private final ConcurrentMap attributes = new ConcurrentHashMap();
-    private String _remoteAddress = "127.0.0.1";
-    private String _localAddress = "127.0.0.1";
+    private String _remoteHost = "127.0.0.1";
+    private String _localHost = "127.0.0.1";
     private int _port = 1;
+    private SocketAddress _localAddress = null;
+    private SocketAddress _remoteAddress = null;
 
     public TestNetworkDriver()
     {
     }
 
-    public void setRemoteAddress(String string)
-    {
-        this._remoteAddress = string;
-    }
-
-    public void setPort(int _port)
-    {
-        this._port = _port;
-    }
-
-    public int getPort()
-    {
-        return _port;
-    }
-
     public void bind(int port, InetAddress[] addresses, ProtocolEngineFactory protocolFactory,
             NetworkDriverConfiguration config, SSLContextFactory sslFactory) throws BindException
     {
@@ -70,12 +57,12 @@ public class TestNetworkDriver implements NetworkDriver
 
     public SocketAddress getLocalAddress()
     {
-        return new InetSocketAddress(_localAddress, _port);
+        return (_localAddress != null) ? _localAddress : new InetSocketAddress(_localHost, _port);
     }
 
     public SocketAddress getRemoteAddress()
     {
-        return new InetSocketAddress(_remoteAddress, _port);
+        return (_remoteAddress != null) ? _remoteAddress : new InetSocketAddress(_remoteHost, _port);
     }
 
     public void open(int port, InetAddress destination, ProtocolEngine engine, NetworkDriverConfiguration config,
@@ -114,9 +101,33 @@ public class TestNetworkDriver implements NetworkDriver
         
     }
 
-    public void setLocalAddress(String localAddress)
+    public void setPort(int port)
     {
-        _localAddress = localAddress;
+        _port = port;
     }
 
+    public int getPort()
+    {
+        return _port;
+    }
+
+    public void setLocalHost(String host)
+    {
+        _localHost = host;
+    }
+
+    public void setRemoteHost(String host)
+    {
+        _remoteHost = host;
+    }
+
+    public void setLocalAddress(SocketAddress address)
+    {
+        _localAddress = address;
+    }
+
+    public void setRemoteAddress(SocketAddress address)
+    {
+        _remoteAddress = address;
+    }
 }