You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/06/22 10:29:53 UTC
[camel] branch main updated: (chores) camel-netty: removed unused parameters
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 6028d713f97 (chores) camel-netty: removed unused parameters
6028d713f97 is described below
commit 6028d713f974a983dabd3403b12dc6685dfbdae4
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Jun 22 11:23:01 2022 +0200
(chores) camel-netty: removed unused parameters
---
.../src/main/java/org/apache/camel/component/netty/NettyHelper.java | 3 +--
.../src/main/java/org/apache/camel/component/netty/NettyProducer.java | 2 +-
.../apache/camel/component/netty/handlers/ServerChannelHandler.java | 4 ++--
3 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
index 6d54b9fd92b..ef208267c7c 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
@@ -86,12 +86,11 @@ public final class NettyHelper {
* @param channel the Netty channel
* @param remoteAddress the remote address when using UDP
* @param body the body to write (send)
- * @param exchange the exchange
* @param listener listener with work to be executed when the operation is complete
*/
public static void writeBodyAsync(
Logger log, Channel channel, SocketAddress remoteAddress, Object body,
- Exchange exchange, ChannelFutureListener listener) {
+ ChannelFutureListener listener) {
ChannelFuture future;
if (remoteAddress != null) {
if (log.isDebugEnabled()) {
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyProducer.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyProducer.java
index 8b96ef3e27f..af376835c48 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyProducer.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyProducer.java
@@ -355,7 +355,7 @@ public class NettyProducer extends DefaultAsyncProducer {
}
// write body
- NettyHelper.writeBodyAsync(LOG, channel, remoteAddress, body, exchange, new ChannelFutureListener() {
+ NettyHelper.writeBodyAsync(LOG, channel, remoteAddress, body, new ChannelFutureListener() {
public void operationComplete(ChannelFuture channelFuture) throws Exception {
LOG.trace("Operation complete {}", channelFuture);
if (!channelFuture.isSuccess()) {
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/handlers/ServerChannelHandler.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/handlers/ServerChannelHandler.java
index 55d3a20980c..899f52c32e9 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/handlers/ServerChannelHandler.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/handlers/ServerChannelHandler.java
@@ -185,10 +185,10 @@ public class ServerChannelHandler extends SimpleChannelInboundHandler<Object> {
// we got a body to write
ChannelFutureListener listener = createResponseFutureListener(consumer, exchange, ctx.channel().remoteAddress());
if (consumer.getConfiguration().isTcp()) {
- NettyHelper.writeBodyAsync(LOG, ctx.channel(), null, body, exchange, listener);
+ NettyHelper.writeBodyAsync(LOG, ctx.channel(), null, body, listener);
} else {
NettyHelper.writeBodyAsync(LOG, ctx.channel(),
- exchange.getProperty(NettyConstants.NETTY_REMOTE_ADDRESS, SocketAddress.class), body, exchange,
+ exchange.getProperty(NettyConstants.NETTY_REMOTE_ADDRESS, SocketAddress.class), body,
listener);
}
}