You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by "Claus Ibsen (JIRA)" <ji...@apache.org> on 2009/05/14 07:44:50 UTC
[jira] Resolved: (CAMEL-1610) unexpected mina exception with tcp
and sync=false
[ https://issues.apache.org/activemq/browse/CAMEL-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Claus Ibsen resolved CAMEL-1610.
--------------------------------
Resolution: Working as Designed
Assignee: Claus Ibsen
Not a bug.
> unexpected mina exception with tcp and sync=false
> -------------------------------------------------
>
> Key: CAMEL-1610
> URL: https://issues.apache.org/activemq/browse/CAMEL-1610
> Project: Apache Camel
> Issue Type: Bug
> Components: camel-mina
> Affects Versions: 1.6.0
> Environment: camel-core-1.6.0, camel-mina-1.6.0, mina-core-1.1.7
> Reporter: Ethan Aubin
> Assignee: Claus Ibsen
>
> Hi,
> I've a client that should connect to mina and will push over messages and excepts no response. I think I should be using something like the following unit test which fails raising an exception (stacktrace at end of bug report). I'm not clear if this is a mina or camel problem.
> public void testTcpReceipt() throws Exception {
> CamelContext context = new DefaultCamelContext();
>
> final Endpoint inEndpoint = context.getEndpoint("mina:tcp://127.0.0.1:15001?sync=false");
> context.addRoutes(
> new RouteBuilder() {
> @Override
> public void configure() {
> from(inEndpoint).
> process(new Processor() {
> public void process(Exchange exchange) throws Exception {
> System.out.println("exchange.getOut().getBody(): " + exchange.getOut().getBody());
> }
> }).
> to("log:loggingCategoryFoo?level=INFO");
> }
> });
> context.start();
>
> Socket socket = new Socket();
> socket.connect(new InetSocketAddress("127.0.0.1", 15001));
> PrintWriter writer = new PrintWriter(socket.getOutputStream());
> writer.write("Hello\nApache\nCamel\n");
> writer.flush();
> Thread.sleep(1000);
> socket.close();
> context.stop();
> }
> 38 [AnonymousIoService-2] WARN org.apache.camel.component.mina.MinaConsumer$ReceiveHandler - [/127.0.0.1:51182] Unexpected exception from exceptionCaught handler.
> org.apache.camel.CamelException: org.apache.mina.filter.codec.ProtocolDecoderException: org.apache.mina.common.BufferDataException: dataLength: 1214606444 (Hexdump: 48 65 6C 6C 6F 0A 41 70 61 63 68 65 0A 43 61 6D 65 6C 0A)
> at org.apache.camel.component.mina.MinaConsumer$ReceiveHandler.exceptionCaught(MinaConsumer.java:88)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.exceptionCaught(AbstractIoFilterChain.java:564)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextExceptionCaught(AbstractIoFilterChain.java:345)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$1000(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.exceptionCaught(AbstractIoFilterChain.java:643)
> at org.apache.mina.common.IoFilterAdapter.exceptionCaught(IoFilterAdapter.java:75)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextExceptionCaught(AbstractIoFilterChain.java:345)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$1000(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.exceptionCaught(AbstractIoFilterChain.java:643)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:224)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:637)
> Caused by: org.apache.mina.filter.codec.ProtocolDecoderException: org.apache.mina.common.BufferDataException: dataLength: 1214606444 (Hexdump: 48 65 6C 6C 6F 0A 41 70 61 63 68 65 0A 43 61 6D 65 6C 0A)
> at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:165)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextMessageReceived(AbstractIoFilterChain.java:299)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$1100(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.messageReceived(AbstractIoFilterChain.java:648)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:220)
> ... 5 more
> Caused by: org.apache.mina.common.BufferDataException: dataLength: 1214606444
> at org.apache.mina.common.ByteBuffer.prefixedDataAvailable(ByteBuffer.java:1631)
> at org.apache.mina.filter.codec.serialization.ObjectSerializationDecoder.doDecode(ObjectSerializationDecoder.java:88)
> at org.apache.mina.filter.codec.CumulativeProtocolDecoder.decode(CumulativeProtocolDecoder.java:133)
> at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:158)
> ... 9 more
> May 13, 2009 10:15:13 AM org.apache.camel.component.mina.MinaConsumer doStop
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.