camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ethan Aubin (JIRA)" <j...@apache.org>
Subject [jira] Commented: (CAMEL-1610) unexpected mina exception with tcp and sync=false
Date Wed, 13 May 2009 14:52:50 GMT

    [ https://issues.apache.org/activemq/browse/CAMEL-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=51667#action_51667
] 

Ethan Aubin commented on CAMEL-1610:
------------------------------------

Thats good to know. Though, using the endpoint "mina:tcp://127.0.0.1:15001?textline=true?sync=false"
I still get the exception. 

> 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
>
> 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.


Mime
View raw message