svn commit: r1431819 - in /camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty: NettyConstants.java NettyEndpoint.java

[ningjiang]

Author: ningjiang
Date: Fri Jan 11 02:25:43 2013
New Revision: 1431819

URL: http://svn.apache.org/viewvc?rev=1431819&view=rev
Log:
CAMEL-5955 Put the LocalAddress into the message header

Modified:
    
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConstants.java
    
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java

Modified: 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConstants.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConstants.java?rev=1431819&r1=1431818&r2=1431819&view=diff
==============================================================================
--- 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConstants.java
 (original)
+++ 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConstants.java
 Fri Jan 11 02:25:43 2013
@@ -27,6 +27,7 @@ public final class NettyConstants {
     public static final String NETTY_CHANNEL_HANDLER_CONTEXT = 
"CamelNettyChannelHandlerContext";
     public static final String NETTY_MESSAGE_EVENT = "CamelNettyMessageEvent";
     public static final String NETTY_REMOTE_ADDRESS = 
"CamelNettyRemoteAddress";
+    public static final String NETTY_LOCAL_ADDRESS = "CamelNettyLocalAddress";
 
     private NettyConstants() {
         // Utility class

Modified: 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java?rev=1431819&r1=1431818&r2=1431819&view=diff
==============================================================================
--- 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
 (original)
+++ 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
 Fri Jan 11 02:25:43 2013
@@ -54,6 +54,7 @@ public class NettyEndpoint extends Defau
         
exchange.getIn().setHeader(NettyConstants.NETTY_CHANNEL_HANDLER_CONTEXT, ctx);
         exchange.getIn().setHeader(NettyConstants.NETTY_MESSAGE_EVENT, 
messageEvent);
         exchange.getIn().setHeader(NettyConstants.NETTY_REMOTE_ADDRESS, 
messageEvent.getRemoteAddress());
+        exchange.getIn().setHeader(NettyConstants.NETTY_LOCAL_ADDRESS, 
messageEvent.getChannel().getLocalAddress());
         NettyPayloadHelper.setIn(exchange, messageEvent.getMessage());
         return exchange;
     }