You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/01/11 03:25:44 UTC
svn commit: r1431819 - in
/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty:
NettyConstants.java NettyEndpoint.java
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;
}