Asynch Bi-Directional Persistent Socket

["LOPEZ, MAURICIO" <ml...@att.com>]

Hello, I have an IBM-Streams backend that communicates natively using a custom socket passing tuples of data.

This is currently setup as a bi-directional persistent asynchronous TCP-IP socket.   We are seeing that our camel instance is initiating a close on the socket. We need this socket to remain open.

Thanks in advance for your help,
Mauricio

Here is our route...
<route trace="true" xmlns="http://camel.apache.org/schema/spring"
        errorHandlerRef="defaultErrorHandler">

        <from uri="direct:sourceRoute" />
                <setHeader headerName="NETTY_CLOSE_CHANNEL_WHEN_COMPLETE">
                    <groovy>
                       return Boolean.FALSE;
                    </groovy>
                </setHeader>
               <loadBalance>
                   <roundRobin/>
                   <inOut uri="netty:tcp://{{streamsIP1}}?textline=true&keepAlive=true&disconnectOnNoReply=false&option.child.keepAlive=true&sync=true&decoderMaxLineLength={{restMaxLineLength}}&autoAppendDelimiter=false&disconnect={{disconnect}}&producerPoolMaxActive={{producerPoolMaxActive}}&producerPoolMinEvictableIdle={{producerPoolMinEvictableIdle}}" />
                   <inOut uri="netty:tcp://{{streamsIP2}}?textline=true&keepAlive=true&disconnectOnNoReply=false&option.child.keepAlive=true&sync=true&decoderMaxLineLength={{restMaxLineLength}}&autoAppendDelimiter=false&disconnect={{disconnect}}&producerPoolMaxActive={{producerPoolMaxActive}}&producerPoolMinEvictableIdle={{producerPoolMinEvictableIdle}}" />
                   <inOut uri="netty:tcp://{{streamsIP3}}?textline=true&keepAlive=true&disconnectOnNoReply=false&option.child.keepAlive=true&sync=true&decoderMaxLineLength={{restMaxLineLength}}&autoAppendDelimiter=false&disconnect={{disconnect}}&producerPoolMaxActive={{producerPoolMaxActive}}&producerPoolMinEvictableIdle={{producerPoolMinEvictableIdle}}" />
               </loadBalance>
               <to uri="bean:source?method=process" />
               <to uri="bean:cache?method=resume" />

            <onException>
                <exception>com.att.csi.tdice.recommendation.validation.CustomBuilderException</exception>
                <exception>java.lang.Exception</exception>
                <handled>
                        <constant>true</constant>
                </handled>
                <to uri="bean:exceptionCaught?method=process" />
                <to uri="bean:cache?method=resume" />

            </onException>
</route>



Mauricio Lopez
  [http://presence.q.att.com/presence/ml5174.gif]  :  ml5174<qto://talk/ml5174>