svn commit: r1509531 - /synapse/trunk/java/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/pollingtask/AMQPSimpleConsumerTask.java

[rajikak]

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);
             }
         }
     }