From d52e6ac042850a6a4353972f433676bd384c9189 Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Wed, 8 Feb 2006 11:03:02 +0000
Subject: [PATCH] support defining local address and port for a socket - e.g:
 ssl://localhost:5666/localhost:60606 where the path (localhost:60606) -
 defines the local address and local port

For jira issue: AMQ-529

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@375923 13f79535-47bb-0310-9956-ffa450edef68
---
 .../transport/tcp/TcpTransportFactory.java    | 42 +++++++++++++------
 1 file changed, 29 insertions(+), 13 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
index f0bcf618bc..bc1d02d583 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
@@ -16,6 +16,14 @@
  */
 package org.apache.activemq.transport.tcp;
 
+import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.UnknownHostException;
+import java.util.HashMap;
+import java.util.Map;
+import javax.net.ServerSocketFactory;
+import javax.net.SocketFactory;
 import org.activeio.command.WireFormat;
 import org.apache.activemq.openwire.OpenWireFormat;
 import org.apache.activemq.transport.MutexTransport;
@@ -28,19 +36,11 @@ import org.apache.activemq.transport.WireFormatNegotiator;
 import org.apache.activemq.util.IOExceptionSupport;
 import org.apache.activemq.util.IntrospectionSupport;
 import org.apache.activemq.util.URISupport;
-
-import javax.net.ServerSocketFactory;
-import javax.net.SocketFactory;
-
-import java.io.IOException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.net.UnknownHostException;
-import java.util.HashMap;
-import java.util.Map;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 
 public class TcpTransportFactory extends TransportFactory {
-
+    private static final Log log = LogFactory.getLog(TcpTransportFactory.class);
     public TransportServer doBind(String brokerId, final URI location) throws IOException {
         try {
             Map options = new HashMap(URISupport.parseParamters(location));
@@ -90,8 +90,24 @@ public class TcpTransportFactory extends TransportFactory {
         return transport;
     }
 
-    protected Transport createTransport(URI location, WireFormat wf) throws UnknownHostException, IOException {
-        return new TcpTransport(wf, location);
+    protected Transport createTransport(URI location,WireFormat wf) throws UnknownHostException,IOException{
+        URI localLocation=null;
+        String path=location.getPath();
+        // see if the path is a local URI location
+        if(path!=null&&path.length()>0){
+            int localPortIndex=path.indexOf(':');
+            try{
+                Integer.parseInt(path.substring((localPortIndex+1),path.length()));
+                String localString=location.getScheme()+ ":/" + path;
+                localLocation=new URI(localString);
+            }catch(Exception e){
+                log.warn("path isn't a valid local location for TcpTransport to use",e);
+            }
+        }
+        if(localLocation!=null){
+            return new TcpTransport(wf,location,localLocation);
+        }
+        return new TcpTransport(wf,location);
     }
 
     protected ServerSocketFactory createServerSocketFactory() {