You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Willem Jiang <wi...@gmail.com> on 2009/08/03 04:05:49 UTC
Re: issue with spring JMS example
Form the stack trace, it looks like the client stop the connection when
the broker wants to read more from it.
It should be OK, if your client can send and receive the message.
Willem
Mick Knutson wrote:
> http://camel.apache.org/tutorial-jmsremoting.html
>
> I start the server up in 1 cmd window.
>
> Then I start another cmd window and run the client
>
> *[mple.client.CamelClient.main()] JmsProducer DEBUG Reply
> recieved. Setting reply as OUT message: 66
> *
>
>
> In the server, I get this error:
>
> [ansport: tcp:///127.0.0.1:1873] Transport DEBUG
> Transport failed: java.net.SocketException: Connection reset
> *java.net.SocketException: Connection reset*
> at java.net.SocketInputStream.read(SocketInputStream.java:168)
> at
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
> at
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
> at java.io.DataInputStream.readInt(DataInputStream.java:353)
> at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
> at
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:210)
> at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:202)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> at java.lang.Thread.run(Thread.java:595)
>
>
> ---
> Thank You…
>
> Mick Knutson, President
>
> BASE Logic, Inc.
> Enterprise Architecture, Design, Mentoring & Agile Consulting
> p. (866) BLiNC-411: (254-6241-1)
> f. (415) 685-4233
>
> Website: http://baselogic.com
> Linked IN: http://linkedin.com/in/mickknutson
> Vacation Rental: http://tahoe.baselogic.com
> ---
>
Re: issue with spring JMS example
Posted by Mick Knutson <mk...@baselogic.com>.
I have gone through many iterations. I finally started the server up with
mvn camel:run then run my JUnit tests and they work.
I have another email to the list about another issue I am having trying to
get a ConsumerTemplate though. I am nt able to get a JUNit client to create
a consumerTemplate so I can sonsume topic messages from my server.
Would you liek me to post that here, or on the other email?
your help is greatly appreciated!!!!!
---
Thank You…
Mick Knutson, President
BASE Logic, Inc.
Enterprise Architecture, Design, Mentoring & Agile Consulting
p. (866) BLiNC-411: (254-6241-1)
f. (415) 685-4233
Website: http://baselogic.com
Linked IN: http://linkedin.com/in/mickknutson
Vacation Rental: http://tahoe.baselogic.com
---
On Sun, Aug 2, 2009 at 7:05 PM, Willem Jiang <wi...@gmail.com> wrote:
>
> Form the stack trace, it looks like the client stop the connection when the
> broker wants to read more from it.
>
> It should be OK, if your client can send and receive the message.
>
> Willem
>
>
> Mick Knutson wrote:
>
>> http://camel.apache.org/tutorial-jmsremoting.html
>>
>> I start the server up in 1 cmd window.
>>
>> Then I start another cmd window and run the client
>>
>> *[mple.client.CamelClient.main()] JmsProducer DEBUG
>> Reply
>> recieved. Setting reply as OUT message: 66
>> *
>>
>>
>> In the server, I get this error:
>>
>> [ansport: tcp:///127.0.0.1:1873] Transport DEBUG
>> Transport failed: java.net.SocketException: Connection reset
>> *java.net.SocketException: Connection reset*
>> at java.net.SocketInputStream.read(SocketInputStream.java:168)
>> at
>>
>> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
>> at
>>
>> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
>> at java.io.DataInputStream.readInt(DataInputStream.java:353)
>> at
>>
>> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
>> at
>>
>> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:210)
>> at
>>
>> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:202)
>> at
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
>> at java.lang.Thread.run(Thread.java:595)
>>
>>
>> ---
>> Thank You…
>>
>> Mick Knutson, President
>>
>> BASE Logic, Inc.
>> Enterprise Architecture, Design, Mentoring & Agile Consulting
>> p. (866) BLiNC-411: (254-6241-1)
>> f. (415) 685-4233
>>
>> Website: http://baselogic.com
>> Linked IN: http://linkedin.com/in/mickknutson
>> Vacation Rental: http://tahoe.baselogic.com
>> ---
>>
>>
>