activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject git commit: add ability to do port mapping when publishing connector uris; important in restricting environments
Date Tue, 03 Sep 2013 15:07:26 GMT
Updated Branches:
  refs/heads/trunk ccc85af30 -> 40af36e93


add ability to do port mapping when publishing connector uris; important in restricting environments


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/40af36e9
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/40af36e9
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/40af36e9

Branch: refs/heads/trunk
Commit: 40af36e93443e4ae1a302530f52ca662f9ef79ab
Parents: ccc85af
Author: Dejan Bosanac <dejan@nighttale.net>
Authored: Tue Sep 3 17:06:41 2013 +0200
Committer: Dejan Bosanac <dejan@nighttale.net>
Committed: Tue Sep 3 17:07:13 2013 +0200

----------------------------------------------------------------------
 .../apache/activemq/broker/PublishedAddressPolicy.java  | 12 ++++++++++++
 1 file changed, 12 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/40af36e9/activemq-broker/src/main/java/org/apache/activemq/broker/PublishedAddressPolicy.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/PublishedAddressPolicy.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/PublishedAddressPolicy.java
index 01f22d3..0814a41 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/PublishedAddressPolicy.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/PublishedAddressPolicy.java
@@ -19,6 +19,7 @@ package org.apache.activemq.broker;
 import java.net.InetAddress;
 import java.net.URI;
 import java.net.UnknownHostException;
+import java.util.HashMap;
 import java.util.Locale;
 
 import org.apache.activemq.util.InetAddressUtil;
@@ -34,6 +35,7 @@ public class PublishedAddressPolicy {
 
     private String clusterClientUriQuery;
     private PublishedHostStrategy publishedHostStrategy = PublishedHostStrategy.DEFAULT;
+    private HashMap<Integer, Integer> portMapping = new HashMap<Integer, Integer>();
 
     /**
      * Defines the value of the published host value.
@@ -70,6 +72,9 @@ public class PublishedAddressPolicy {
         String userInfo = getPublishedUserInfoValue(connectorURI.getUserInfo());
         String host = getPublishedHostValue(connectorURI.getHost());
         int port = connectorURI.getPort();
+        if (portMapping.containsKey(port)) {
+            port = portMapping.get(port);
+        }
         String path = getPublishedPathValue(connectorURI.getPath());
         String fragment = getPublishedFragmentValue(connectorURI.getFragment());
 
@@ -197,4 +202,11 @@ public class PublishedAddressPolicy {
     public void setPublishedHostStrategy(String strategy) {
         this.publishedHostStrategy = PublishedHostStrategy.getValue(strategy);
     }
+
+    /**
+     * @param portMapping map the ports in restrictive environments
+     */
+    public void setPortMapping(HashMap<Integer, Integer> portMapping) {
+        this.portMapping = portMapping;
+    }
 }


Mime
View raw message