(camel) branch main updated: CAMEL-20717 Throw created exception in TcpSocketConsumerRunnable (#13965)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus 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 b1fe8f717f6 CAMEL-20717 Throw created exception in 
TcpSocketConsumerRunnable (#13965)
b1fe8f717f6 is described below

commit b1fe8f717f618f6d7dc11aebd9541e23cd7565a4
Author: Dmitry Kryukov <d...@users.noreply.github.com>
AuthorDate: Thu May 2 15:16:33 2024 +0300

    CAMEL-20717 Throw created exception in TcpSocketConsumerRunnable (#13965)
    
    * CAMEL-20717 Throw created exception in TcpSocketConsumerRunnable
    
    * CAMEL-20717 Removed the exception
    
    * CAMEL-20717 removed the unused import
---
 .../camel/component/mllp/internal/TcpSocketConsumerRunnable.java      | 4 ----
 1 file changed, 4 deletions(-)

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 3d9e8f636fe..f8c6da04cd7 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
@@ -22,7 +22,6 @@ import java.net.SocketAddress;
 import java.net.SocketTimeoutException;
 
 import org.apache.camel.Route;
-import org.apache.camel.component.mllp.MllpInvalidMessageException;
 import org.apache.camel.component.mllp.MllpSocketException;
 import org.apache.camel.component.mllp.MllpTcpServerConsumer;
 import org.apache.camel.spi.UnitOfWork;
@@ -189,9 +188,6 @@ public class TcpSocketConsumerRunnable implements Runnable {
                         log.debug("No data received - ignoring timeout");
                     } else {
                         mllpBuffer.resetSocket(clientSocket);
-                        new MllpInvalidMessageException(
-                                "Timeout receiving complete message payload", 
mllpBuffer.toByteArrayAndReset(), timeoutEx,
-                                logPhi);
                         consumer.handleMessageTimeout("Timeout receiving 
complete message payload",
                                 mllpBuffer.toByteArrayAndReset(), timeoutEx);
                     }