hi,

I am not really sure is this is related to the problem, but I noticed that the 
SocketTimeout is often too short and somewhere it get lowered to 500ms.
I was not able to establish a ssl handshake, when I was useing the debugging 
function and got many read timeout errors. Maybe it is also a Timeout problem 
with large messages.

-----Ursprüngliche Nachricht-----
Von: Steve Barham [mailto:[EMAIL PROTECTED]
Gesendet: Dienstag, 21. März 2006 10:09
An: [email protected]
Betreff: Re: SSL transport failure on large messages?



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 =
> [EMAIL PROTECTED], 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(ResponseCorrelatorjava: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/



This mail has originated outside your organization,
either from an external partner or the Global Internet.
Keep this in mind if you answer this message.

This mail has originated outside your organization, either from an external 
partner or the Global Internet. Keep this in mind if you answer this message.

Reply via email to