activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Steve Barham" <steve.bar...@formicary.net>
Subject Re: SSL transport failure on large messages?
Date Tue, 21 Mar 2006 14:03:29 GMT
M4

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


-- 
Steve Barham                       tel: +44 (0)7973 199 471
Systems Engineer
Formicary - delivering quality financial technology solutions
http://www.formicary.net/


Mime
View raw message