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
commit 581b24a883497bed320e4ce2b5947c500a2b2e19 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Thu Jun 23 06:51:12 2022 +0200 (chores) camel-netty: removed unused parameters --- .../component/netty/handlers/ServerChannelHandler.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) 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 899f52c32e9..9c9267cc2d5 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 @@ -107,9 +107,9 @@ public class ServerChannelHandler extends SimpleChannelInboundHandler<Object> { // process accordingly to endpoint configuration if (consumer.getEndpoint().isSynchronous()) { - processSynchronously(exchange, ctx, msg); + processSynchronously(exchange, ctx); } else { - processAsynchronously(exchange, ctx, msg); + processAsynchronously(exchange, ctx); } } @@ -132,11 +132,11 @@ public class ServerChannelHandler extends SimpleChannelInboundHandler<Object> { // noop } - private void processSynchronously(final Exchange exchange, final ChannelHandlerContext ctx, final Object message) { + private void processSynchronously(final Exchange exchange, final ChannelHandlerContext ctx) { try { consumer.getProcessor().process(exchange); if (consumer.getConfiguration().isSync()) { - sendResponse(message, ctx, exchange); + sendResponse(ctx, exchange); } } catch (Exception e) { consumer.getExceptionHandler().handleException(e); @@ -146,12 +146,12 @@ public class ServerChannelHandler extends SimpleChannelInboundHandler<Object> { } } - private void processAsynchronously(final Exchange exchange, final ChannelHandlerContext ctx, final Object message) { + private void processAsynchronously(final Exchange exchange, final ChannelHandlerContext ctx) { consumer.getAsyncProcessor().process(exchange, doneSync -> { // send back response if the communication is synchronous try { if (consumer.getConfiguration().isSync()) { - sendResponse(message, ctx, exchange); + sendResponse(ctx, exchange); } } catch (Exception e) { consumer.getExceptionHandler().handleException(e); @@ -162,7 +162,7 @@ public class ServerChannelHandler extends SimpleChannelInboundHandler<Object> { }); } - private void sendResponse(Object message, ChannelHandlerContext ctx, Exchange exchange) throws Exception { + private void sendResponse(ChannelHandlerContext ctx, Exchange exchange) throws Exception { Object body = getResponseBody(exchange); if (body == null) {
