Is there a TCP connector without polling?

Hansen Gao

2012-06-19 05:32:32 UTC

Thanks for your reply, David.
 
As you suggested, I changed my mflow file:
 
<code>
 
<?xml version="1.0" encoding="UTF-8"?>
 
<mule xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:tcp="http://www.mulesoft.org/schema/mule/tcp" xmlns:udp="http://www.mulesoft.org/schema/mule/udp" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" xmlns:core="http://www.mulesoft.org/schema/mule/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="EE-3.2.2" xsi:schemaLocation="
 
http://www.mulesoft.org/schema/mule/tcp http://www.mulesoft.org/schema/mule/tcp/current/mule-tcp.xsd
 
http://www.mulesoft.org/schema/mule/udp http://www.mulesoft.org/schema/mule/udp/current/mule-udp.xsd
 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd ">
 
<tcp:connector name="TCP_C_L" validateConnections="false" receiveBufferSize="102400" sendBufferSize="102400" doc:name="TCP"/>
 
<tcp:connector name="TCP_C_81" validateConnections="false" receiveBufferSize="102400" sendBufferSize="102400" doc:name="TCP"/>
 
<flow name="tcpFlow1" doc:name="tcpFlow1">
 
<tcp:inbound-endpoint address="tcp://localhost:3600" responseTimeout="10000" exchange-pattern="request-response" connector-ref="TCP_C_L" doc:name="TCP"/>
 
<tcp:outbound-endpoint host="192.168.140.81" port="3600" responseTimeout="10000" exchange-pattern="request-response" connector-ref="TCP_C_81" doc:name="TCP"/>
 
</flow>
 
</mule>
 
</code>
 
But I still get the same error:
 
<code>
 
ERROR 2012-06-19 13:24:11,748 [[mytest1].TCP_C_L.receiver.02] org.mule.exception.DefaultSystemExceptionStrategy: Caught exception in Exception Strategy: An error occurred while verifying your connection. You may not be using a consistent protocol on your TCP transport. Please read the documentation for the TCP transport, paying particular attention to the protocol parameter.
 
java.io.IOException: An error occurred while verifying your connection. You may not be using a consistent protocol on your TCP transport. Please read the documentation for the TCP transport, paying particular attention to the protocol parameter.
 
at org.mule.transport.tcp.protocols.SafeProtocol.helpUser(SafeProtocol.java:110)
 
at org.mule.transport.tcp.protocols.SafeProtocol.assertSiblingSafe(SafeProtocol.java:83)
 
at org.mule.transport.tcp.protocols.SafeProtocol.read(SafeProtocol.java:37)
 
at org.mule.transport.tcp.TcpMessageReceiver$TcpWorker.getNextMessage(TcpMessageReceiver.java:364)
 
at org.mule.transport.AbstractReceiverResourceWorker.doRun(AbstractReceiverResourceWorker.java:44)
 
at org.mule.transport.AbstractReceiverWorker.run(AbstractReceiverWorker.java:63)
 
at org.mule.work.WorkerContext.run(WorkerContext.java:310)
 
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
 
at java.lang.Thread.run(Thread.java:662)
 
Caused by: java.io.IOException: Length 189616968 exceeds limit: 26
 
at org.mule.transport.tcp.protocols.LengthProtocol.read(LengthProtocol.java:75)
 
at org.mule.transport.tcp.protocols.SafeProtocol.assertSiblingSafe(SafeProtocol.java:79)
 
... 8 more
 
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
 
at java.lang.Thread.run(Thread.java:662)
 
Caused by: java.io.IOException: Length 189616968 exceeds limit: 26
 
</code>
 
The Length 189616968 is not right.
 
The limit 26 is not right either.
 
at org.mule.transport.tcp.protocols.LengthProtocol.read(LengthProtocol.java:75)
 
at org.mule.transport.tcp.protocols.SafeProtocol.assertSiblingSafe(SafeProtocol.java:79)
 
... 8 more

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email