activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: SSL transport failure on large messages?
Date Tue, 21 Mar 2006 13:56:56 GMT
which version are you using? 4.0-M4 or a snapshot?

James

On 3/21/06, Steve Barham <steve.barham@formicary.net> wrote:
> Does anyone have any insight into this problem? James?
>
> Steve
>
>
> > Hi again,
> >
> > I'm succesfully using ActiveMQ 4.0 with the SSL transport, but have run
> > into a bit of a problem; a large message which previously would deliver
> > without problem in ActiveMQ 3.2.2 with TCP transport now throws a fat
> > stacktrace my way.
> >
> > Any suggestions from the following trace? The first line is from my
> > application, the rest is AMQ.
> >
> > DEBUG [2006-03-16 10:50:44,890] model.UserManager "Took 2156ms to retrieve
> > all light user value objects"
> > DEBUG [2006-03-16 10:50:46,562] activemq.ActiveMQSession "Sending message:
> > ActiveMQObjectMessage {commandId = 0, responseRequired = false, messageId
> > = ID:gbws-00054766-2268-1142506175890-0:0:1:3:1, originalDestination =
> > null, originalTransactionId = null, producerId =
> > ID:gbws-00054766-2268-1142506175890-0:0:1:3, destination =
> > temp-queue://ID:gbws-00054766-2277-1142506191828-0:0:1, transactionId =
> > null, expiration = 0, timestamp = 1142506245937, arrival = 0,
> > correlationId = 6092480248467635477, replyTo = null, persistent = true,
> > type = null, priority = 4, groupID = null, groupSequence = 0,
> > targetConsumerId = null, compressed = false, userID = null, content =
> > org.activeio.ByteSequence@1c7eef6, marshalledProperties = null,
> > dataStructure = null, redeliveryCounter = 0}"
> >  WARN [2006-03-16 10:50:48,765] activemq.ActiveMQConnection "Async
> > exception with no exception listener: java.io.EOFException: Peer
> > disconnected."
> > java.io.EOFException: Peer disconnected.
> >       at
> > org.activeio.command.AsyncChannelToAsyncCommandChannel$1.onPacket(AsyncChannelToAsyncCommandChannel.java:65)
> >       at
> > org.apache.activemq.transport.activeio.PacketAggregatingAsyncChannel.onPacket(PacketAggregatingAsyncChannel.java:59)
> >       at org.activeio.FilterAsyncChannel.onPacket(FilterAsyncChannel.java:87)
> >       at
> > org.apache.activemq.transport.activeio.ActivityMonitor.onPacket(ActivityMonitor.java:42)
> >       at
> > org.activeio.adapter.SyncToAsyncChannel.run(SyncToAsyncChannel.java:150)
> >       at
> > edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:643)
> >       at
> > edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:668)
> >       at java.lang.Thread.run(Thread.java:534)
> >  WARN [2006-03-16 10:50:48,765] activemq.ActiveMQConnection "Cleanup
> > failed"
> > javax.jms.JMSException: Connection closed by remote host
> >       at
> > org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:57)
> >       at
> > org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1043)
> >       at
> > org.apache.activemq.ActiveMQConnection.cleanup(ActiveMQConnection.java:1191)
> >       at
> > org.apache.activemq.ActiveMQConnection.transportFailed(ActiveMQConnection.java:1585)
> >       at
> > org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1338)
> >       at
> > org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:102)
> >       at
> > org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:102)
> >       at
> > org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:102)
> >       at
> > org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:96)
> >       at
> > org.apache.activemq.transport.activeio.ActiveIOTransport$1.onError(ActiveIOTransport.java:71)
> >       at
> > org.activeio.command.AsyncChannelToAsyncCommandChannel$1.onPacket(AsyncChannelToAsyncCommandChannel.java:65)
> >       at
> > org.apache.activemq.transport.activeio.PacketAggregatingAsyncChannel.onPacket(PacketAggregatingAsyncChannel.java:59)
> >       at org.activeio.FilterAsyncChannel.onPacket(FilterAsyncChannel.java:87)
> >       at
> > org.apache.activemq.transport.activeio.ActivityMonitor.onPacket(ActivityMonitor.java:42)
> >       at
> > org.activeio.adapter.SyncToAsyncChannel.run(SyncToAsyncChannel.java:150)
> >       at
> > edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:643)
> >       at
> > edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:668)
> >       at java.lang.Thread.run(Thread.java:534)
> > Caused by: java.net.SocketException: Connection closed by remote host
> >       at com.sun.net.ssl.internal.ssl.SSLSocketImpl.e(DashoA12275)
> >       at com.sun.net.ssl.internal.ssl.AppOutputStream.write(DashoA12275)
> >       at
> > org.activeio.net.SocketStreamChannel.write(SocketStreamChannel.java:183)
> >       at
> > org.activeio.adapter.OutputStreamChannelToOutputStream.write(OutputStreamChannelToOutputStream.java:48)
> >       at org.activeio.packet.ByteArrayPacket.writeTo(ByteArrayPacket.java:126)
> >       at org.activeio.net.SocketSyncChannel.write(SocketSyncChannel.java:113)
> >       at
> > org.activeio.adapter.SyncToAsyncChannel.write(SyncToAsyncChannel.java:184)
> >       at org.activeio.FilterAsyncChannel.write(FilterAsyncChannel.java:50)
> >       at
> > org.apache.activemq.transport.activeio.ActivityMonitor.write(ActivityMonitor.java:47)
> >       at org.activeio.FilterAsyncChannel.write(FilterAsyncChannel.java:50)
> >       at
> > org.activeio.command.AsyncChannelToAsyncCommandChannel.writeCommand(AsyncChannelToAsyncCommandChannel.java:41)
> >       at
> > org.apache.activemq.transport.activeio.ActiveIOTransport.oneway(ActiveIOTransport.java:95)
> >       at
> > org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:90)
> >       at
> > org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:90)
> >       at
> > org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:65)
> >       at
> > org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
> >       at
> > org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:54)
> >       at
> > org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1041)
> >       ... 16 more
> >
> > Cheers,
> >
> > Steve
> >
>
>
> --
> Steve Barham                       tel: +44 (0)7973 199 471
> Systems Engineer
> Formicary - delivering quality financial technology solutions
> http://www.formicary.net/
>
>


--

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message