activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject [1/4] git commit: Add support for getting the intended host name from the WireFormatInfo in openwire.
Date Mon, 24 Feb 2014 23:59:39 GMT
Repository: activemq-apollo
Updated Branches:
  refs/heads/trunk 1637f4b51 -> 861d918d0


Add support for getting the intended host name from the WireFormatInfo in openwire.


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

Branch: refs/heads/trunk
Commit: 8013addc33ef16180e01a3c77334484c993bda06
Parents: bb366a2
Author: Hiram Chirino <hiram@hiramchirino.com>
Authored: Mon Feb 24 18:54:00 2014 -0500
Committer: Hiram Chirino <hiram@hiramchirino.com>
Committed: Mon Feb 24 18:54:07 2014 -0500

----------------------------------------------------------------------
 .../activemq/apollo/openwire/command/WireFormatInfo.java    | 9 +++++++++
 1 file changed, 9 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-apollo/blob/8013addc/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/command/WireFormatInfo.java
----------------------------------------------------------------------
diff --git a/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/command/WireFormatInfo.java
b/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/command/WireFormatInfo.java
index c368dec..b1d3107 100644
--- a/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/command/WireFormatInfo.java
+++ b/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/command/WireFormatInfo.java
@@ -29,6 +29,7 @@ import org.apache.activemq.apollo.openwire.support.MarshallingSupport;
 import org.fusesource.hawtbuf.Buffer;
 import org.fusesource.hawtbuf.ByteArrayInputStream;
 import org.fusesource.hawtbuf.ByteArrayOutputStream;
+import org.fusesource.hawtbuf.UTF8Buffer;
 
 /**
  * @openwire:marshaller code="1"
@@ -332,4 +333,12 @@ public class WireFormatInfo implements Command, MarshallAware {
     public boolean isShutdownInfo() {
         return false;
     }
+
+    public String getHost() throws IOException {
+        return (String) getProperty("Host");
+    }
+
+    public void setHost(String hostname) throws IOException {
+        setProperty("Host", hostname);
+    }
 }


Mime
View raw message