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/16 07:04:52 UTC
[camel] 04/06: (chores) camel-mllp: removed unused method 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
commit 8c65ba0ac2e591fc288121a2f4ac66c667c4ec8d
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Jun 15 17:39:58 2022 +0200
(chores) camel-mllp: removed unused method parameters
---
.../component/mllp/internal/TcpServerConsumerValidationRunnable.java | 4 ++--
.../camel/component/mllp/internal/TcpSocketConsumerRunnable.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpServerConsumerValidationRunnable.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpServerConsumerValidationRunnable.java
index 02ae650ed5f..ae44243e7a2 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpServerConsumerValidationRunnable.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpServerConsumerValidationRunnable.java
@@ -101,7 +101,7 @@ public class TcpServerConsumerValidationRunnable implements Runnable {
*
* @return the thread name
*/
- String createThreadName(Socket socket) {
+ String createThreadName() {
// Get the URI without options
String fullEndpointKey = consumer.getEndpoint().getEndpointKey();
String endpointKey;
@@ -121,7 +121,7 @@ public class TcpServerConsumerValidationRunnable implements Runnable {
@Override
public void run() {
String originalThreadName = Thread.currentThread().getName();
- Thread.currentThread().setName(createThreadName(clientSocket));
+ Thread.currentThread().setName(createThreadName());
MDC.put(UnitOfWork.MDC_CAMEL_CONTEXT_ID, consumer.getEndpoint().getCamelContext().getName());
Route route = consumer.getRoute();
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpSocketConsumerRunnable.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpSocketConsumerRunnable.java
index 213a472f271..3b16b448f19 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpSocketConsumerRunnable.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/internal/TcpSocketConsumerRunnable.java
@@ -107,7 +107,7 @@ public class TcpSocketConsumerRunnable implements Runnable {
*
* @return the thread name
*/
- String createThreadName(Socket socket) {
+ String createThreadName() {
// Get the URI without options
String fullEndpointKey = consumer.getEndpoint().getEndpointKey();
String endpointKey;
@@ -125,7 +125,7 @@ public class TcpSocketConsumerRunnable implements Runnable {
public void run() {
running = true;
String originalThreadName = Thread.currentThread().getName();
- Thread.currentThread().setName(createThreadName(clientSocket));
+ Thread.currentThread().setName(createThreadName());
MDC.put(UnitOfWork.MDC_CAMEL_CONTEXT_ID, consumer.getEndpoint().getCamelContext().getName());
Route route = consumer.getRoute();