On 21 May 2014 at 11:37:03, Thomas Kristensen (thomas.kristen...@uswitch.com) wrote: > > DefaultExceptionHandler: Consumer > > langohr.consumers.proxy$com.rabbitmq.client.DefaultConsumer$ff19274a@31bdf573 > > > (amq.ctag-GGj0_JfnXHvzpI8YHuHY3w) method handleDelivery > for channel > AMQChannel(amqp://guest@10.0.0.0:5672/,1(http://guest@10.0.0.0:5672/,1)) > threw an exception for channel > AMQChannel(amqp://guest@10.0.0.0:5672/,1(http://guest@10.0.0.0:5672/,1)): > java.net.SocketTimeoutException: Read timed out > at java.net.SocketInputStream.socketRead0(Native Method) > at java.net.SocketInputStream.read(SocketInputStream.java:152) > at java.net.SocketInputStream.read(SocketInputStream.java:122) > 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 > org.apache.http.impl.io.AbstractSessionInputBuffer.fillBuffer(AbstractSessionInputBuffer.java:160) > > at > org.apache.http.impl.io.SocketInputBuffer.fillBuffer(SocketInputBuffer.java:84) > > at > org.apache.http.impl.io.AbstractSessionInputBuffer.read(AbstractSessionInputBuffer.java:206) > > at > org.apache.http.impl.conn.LoggingSessionInputBuffer.read(LoggingSessionInputBuffer.java:82) > > at > org.apache.http.impl.io.ContentLengthInputStream.read(ContentLengthInputStream.java:178) > > at > org.apache.http.conn.EofSensorInputStream.read(EofSensorInputStream.java:138) > > at java.io.FilterInputStream.read(FilterInputStream.java:133) > at java.security.DigestInputStream.read(DigestInputStream.java:161) > at > com.amazonaws.services.s3.internal.DigestValidationInputStream.read(DigestValidationInputStream.java:59) > > at java.io.FilterInputStream.read(FilterInputStream.java:133) > at java.util.zip.InflaterInputStream.fill(InflaterInputStream.java:238) > at java.util.zip.InflaterInputStream.read(InflaterInputStream.java:158) > at java.util.zip.GZIPInputStream.read(GZIPInputStream.java:116) > > > ... secret corporate stuff > > at langohr.consumers$ack_unless_exception$fn__11098.invoke(consumers.clj:124) >
Right, so you have an S3 request that times out in a consumer delivery handler. langohr.consumers/ack-unless-exception does not currently involve any exception handling. It was contributed by someone else so I'm no longer sure what exactly the intent was. What behaviour do you want to see? -- MK Software Engineer, Pivotal/RabbitMQ -- You received this message because you are subscribed to the Google Groups "clojure-rabbitmq" group. To unsubscribe from this group and stop receiving emails from it, send an email to clojure-rabbitmq+unsubscr...@googlegroups.com. For more options, visit https://groups.google.com/d/optout.
