You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by qu...@apache.org on 2018/01/23 17:14:35 UTC

[camel] branch master updated: CAMEL-12182 - reset connection after acknowledgement timeout

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

quinn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 56ce80e  CAMEL-12182 - reset connection after acknowledgement timeout
56ce80e is described below

commit 56ce80ec20b0045d0526229f880c422397720e1c
Author: Quinn Stevenson <qu...@apache.org>
AuthorDate: Tue Jan 23 10:13:59 2018 -0700

    CAMEL-12182 - reset connection after acknowledgement timeout
---
 .../main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
index e91ccb6..929c332 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
@@ -237,6 +237,7 @@ public class MllpTcpClientProducer extends DefaultProducer implements Runnable {
                         exchange.setException(new MllpAcknowledgementTimeoutException("Timeout receiving complete HL7 Acknowledgement", hl7MessageBytes, mllpBuffer.toByteArray(), timeoutEx));
                         mllpBuffer.reset();
                     }
+                    mllpBuffer.resetSocket(socket);
                 }
 
                 if (exchange.getException() == null) {

-- 
To stop receiving notification emails like this one, please contact
quinn@apache.org.