qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Graham Leggett <minf...@sharp.fm>
Subject amqp client: "Connection has been shutdown" triggers stuck thread
Date Fri, 04 Oct 2013 09:53:50 GMT
Hi all,

I have a client that makes once off connections to an activemq server over aqmp to poll for
messages from time to time (no long lived connections are used). This works great for a period
of time, until we suddenly get the unexpected exception below printed to the console. At this
point the qpid aqmp client thread hangs, and our application node becomes stuck.

From what I can see, this tends to happen when it takes use a long time to consume a message
(we are doing heavy processing on the message when it arrives, and may take many tens of seconds,
even minutes).

We are using the trunk version of qpid (to work around another bug).

Does this look familiar to anyone?

javax.net.ssl.SSLException: Connection has been shutdown: javax.net.ssl.SSLException: java.net.SocketException:
Connection reset
        at sun.security.ssl.SSLSocketImpl.checkEOF(SSLSocketImpl.java:1476)
        at sun.security.ssl.AppInputStream.read(AppInputStream.java:103)
        at java.io.InputStream.read(InputStream.java:101)
        at org.apache.qpid.amqp_1_0.client.Connection.doRead(Connection.java:370)
        at org.apache.qpid.amqp_1_0.client.Connection.access$000(Connection.java:42)
        at org.apache.qpid.amqp_1_0.client.Connection$2.run(Connection.java:244)
        at java.lang.Thread.run(Thread.java:724)
Caused by: javax.net.ssl.SSLException: java.net.SocketException: Connection reset
        at sun.security.ssl.Alerts.getSSLException(Alerts.java:208)
        at sun.security.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1886)
        at sun.security.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1844)
        at sun.security.ssl.SSLSocketImpl.handleException(SSLSocketImpl.java:1808)
        at sun.security.ssl.SSLSocketImpl.handleException(SSLSocketImpl.java:1753)
        at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:127)
        at org.apache.qpid.amqp_1_0.framing.ConnectionHandler$BytesOutputHandler.processBytes(ConnectionHandler.java:418)
        at org.apache.qpid.amqp_1_0.framing.ConnectionHandler$HeaderBytesSource.getBytes(ConnectionHandler.java:336)
        at org.apache.qpid.amqp_1_0.framing.ConnectionHandler$SequentialBytesSource.getBytes(ConnectionHandler.java:371)
        at org.apache.qpid.amqp_1_0.framing.ConnectionHandler$BytesOutputHandler.run(ConnectionHandler.java:404)
        ... 1 more
Caused by: java.net.SocketException: Connection reset
        at java.net.SocketInputStream.read(SocketInputStream.java:189)
        at java.net.SocketInputStream.read(SocketInputStream.java:121)
        at sun.security.ssl.InputRecord.readFully(InputRecord.java:442)
        at sun.security.ssl.InputRecord.read(InputRecord.java:480)
        at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:927)
        at sun.security.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1312)
        at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:702)
        at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:122)
        ... 5 more
java.net.SocketException: Connection reset
        at java.net.SocketInputStream.read(SocketInputStream.java:189)
        at java.net.SocketInputStream.read(SocketInputStream.java:121)
        at sun.security.ssl.InputRecord.readFully(InputRecord.java:442)
        at sun.security.ssl.InputRecord.read(InputRecord.java:480)
        at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:927)
        at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:884)
        at sun.security.ssl.AppInputStream.read(AppInputStream.java:102)
        at java.io.InputStream.read(InputStream.java:101)
        at org.apache.qpid.amqp_1_0.client.Connection.doRead(Connection.java:370)
        at org.apache.qpid.amqp_1_0.client.Connection.access$000(Connection.java:42)
        at org.apache.qpid.amqp_1_0.client.Connection$2.run(Connection.java:244)
        at java.lang.Thread.run(Thread.java:724)

Regards,
Graham
--


---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org


Mime
View raw message