You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ra...@apache.org on 2013/08/02 06:12:38 UTC
svn commit: r1509531 -
/synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java
Author: rajikak
Date: Fri Aug 2 04:12:37 2013
New Revision: 1509531
URL: http://svn.apache.org/r1509531
Log:
shut down signal for simple consumer.
Modified:
synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java
Modified: synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java?rev=1509531&r1=1509530&r2=1509531&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java (original)
+++ synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java Fri Aug 2 04:12:37 2013
@@ -28,6 +28,7 @@ package org.apache.synapse.transport.amq
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.QueueingConsumer;
+import com.rabbitmq.client.ShutdownSignalException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.synapse.transport.amqp.AMQPTransportMessage;
@@ -103,6 +104,8 @@ public class AMQPSimpleConsumerTask {
} catch (InterruptedException e) {
log.error("Retrieving task was interrupted", e);
Thread.currentThread().interrupt();
+ } catch (ShutdownSignalException e) {
+ log.error("Shutdown signal was received for simple consumer task", e);
}
}
}