Add extra exception handling

aliesbelik · Oct 29, 2021 · a181010 · a181010
1 parent f18b94b
commit a181010
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPSampler.java b/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPSampler.java
@@ -19,9 +19,11 @@
 
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Address;
+import com.rabbitmq.client.AlreadyClosedException;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.ShutdownSignalException;
 
 public abstract class AMQPSampler extends AbstractSampler implements ThreadListener {
 
@@ -438,6 +440,10 @@ protected void cleanup() {
             }
         } catch (IOException e) {
             log.error("Failed to close connection", e);
+        } catch (AlreadyClosedException e) {
+            log.error("Connection already closed", e);
+        } catch (ShutdownSignalException e) {
+            log.error("Connection shutdown by thread close", e);
         }
     }