[camel] branch master updated: CAMEL-12325 - update lastConnectionActivityTicks in MllpTcpClientProducer

[quinn]

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 e2b1018  CAMEL-12325 - update lastConnectionActivityTicks in 
MllpTcpClientProducer
e2b1018 is described below

commit e2b10183ba735986102799e8d1be28111f11cfc6
Author: Quinn Stevenson <qu...@apache.org>
AuthorDate: Tue Mar 6 15:08:11 2018 -0700

    CAMEL-12325 - update lastConnectionActivityTicks in MllpTcpClientProducer
---
 .../java/org/apache/camel/component/mllp/MllpTcpClientProducer.java     | 2 ++
 1 file changed, 2 insertions(+)

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 8cbb492..9b7ca63 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
@@ -124,6 +124,7 @@ public class MllpTcpClientProducer extends DefaultProducer 
implements Runnable {
     @Override
     public synchronized void process(Exchange exchange) throws Exception {
         log.trace("Processing Exchange {}", exchange.getExchangeId());
+        getEndpoint().updateLastConnectionActivityTicks();
 
         Message message = exchange.hasOut() ? exchange.getOut() : 
exchange.getIn();
 
@@ -272,6 +273,7 @@ public class MllpTcpClientProducer extends DefaultProducer 
implements Runnable {
 
         } catch (IOException ioEx) {
             exchange.setException(ioEx);
+            mllpBuffer.resetSocket(socket);
         } finally {
             mllpBuffer.reset();
         }

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