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/23 05:56:21 UTC
[camel] branch main updated (8d412f0a409 -> cbcadb426cd)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 8d412f0a409 Upgrade dependencies
new 581b24a8834 (chores) camel-netty: removed unused parameters
new cbcadb426cd (chores) camel-netty-http: removed unused parameters
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/component/netty/http/NettyHttpComponent.java | 6 +++---
.../component/netty/handlers/ServerChannelHandler.java | 14 +++++++-------
2 files changed, 10 insertions(+), 10 deletions(-)
[camel] 02/02: (chores) camel-netty-http: removed unused parameters
Posted by or...@apache.org.
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 cbcadb426cd3cbbb7ec7dbbd9318bac10852eec1
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Jun 23 06:52:01 2022 +0200
(chores) camel-netty-http: removed unused parameters
---
.../org/apache/camel/component/netty/http/NettyHttpComponent.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java
index d188214e4ac..6d86e5ad7e9 100644
--- a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java
+++ b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java
@@ -356,7 +356,7 @@ public class NettyHttpComponent extends NettyComponent
CamelContext camelContext, Processor processor, String verb, String basePath, String uriTemplate,
String consumes, String produces, RestConfiguration configuration, Map<String, Object> parameters)
throws Exception {
- return doCreateConsumer(camelContext, processor, verb, basePath, uriTemplate, consumes, produces, configuration,
+ return doCreateConsumer(camelContext, processor, verb, basePath, uriTemplate, configuration,
parameters, false);
}
@@ -366,12 +366,12 @@ public class NettyHttpComponent extends NettyComponent
RestConfiguration configuration, Map<String, Object> parameters)
throws Exception {
// reuse the createConsumer method we already have. The api need to use GET and match on uri prefix
- return doCreateConsumer(camelContext, processor, "GET", contextPath, null, null, null, configuration, parameters, true);
+ return doCreateConsumer(camelContext, processor, "GET", contextPath, null, configuration, parameters, true);
}
Consumer doCreateConsumer(
CamelContext camelContext, Processor processor, String verb, String basePath, String uriTemplate,
- String consumes, String produces, RestConfiguration configuration, Map<String, Object> parameters, boolean api)
+ RestConfiguration configuration, Map<String, Object> parameters, boolean api)
throws Exception {
String path = basePath;
[camel] 01/02: (chores) camel-netty: removed unused parameters
Posted by or...@apache.org.
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 <an...@gmail.com>
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) {