Consumer shutdown signal exception

example/non_rails_app/Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: ../../
   specs:
-    rabbit_feed (2.4.1)
+    rabbit_feed (2.4.2)
       activemodel (>= 3.2.0, < 5.0.0)
       activesupport (>= 3.2.0, < 5.0.0)
       avro (>= 1.5.4, < 1.8.0)

example/rails_app/Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: ../../
   specs:
-    rabbit_feed (2.4.1)
+    rabbit_feed (2.4.2)
       activemodel (>= 3.2.0, < 5.0.0)
       activesupport (>= 3.2.0, < 5.0.0)
       avro (>= 1.5.4, < 1.8.0)

lib/rabbit_feed/consumer_connection.rb

@@ -37,7 +37,7 @@ def consume &block
           end
 
           sleep # Sleep indefinitely, as the consumer runs in its own thread
-        rescue SystemExit, Interrupt
+        rescue SystemExit, Interrupt, SignalException
           RabbitFeed.log.info {{ event: :unsubscribe_from_queue, queue: RabbitFeed.configuration.queue }}
         ensure
           (cancel_consumer consumer) if consumer.present?

lib/rabbit_feed/version.rb

@@ -1,3 +1,3 @@
 module RabbitFeed
-  VERSION = '2.4.1'
+  VERSION = '2.4.2'
 end

spec/lib/rabbit_feed/consumer_connection_spec.rb

@@ -79,6 +79,34 @@ module RabbitFeed
 
       context 'when an exception is raised' do
 
+        context 'when the exception is' do
+          [SystemExit.new, Interrupt.new, SignalException.new('SIGTERM')].each do |exception|
+            context exception.to_s do
+              let!(:logger) do
+                test_logger_string_io = StringIO.new
+                logger = Logger.new test_logger_string_io
+                logger.formatter = RabbitFeed::JsonLogFormatter
+                old_logger = RabbitFeed.log
+                RabbitFeed.log = logger
+                test_logger_string_io
+              end
+
+              before { allow(subject).to receive(:handle_message).and_raise(exception) }
+
+              it 'does not re-raise error' do
+                expect { subject.consume { } }.to_not raise_error
+              end
+
+              it 'logs unsubscribe_from_queue' do
+                subject.consume { }
+
+                expect(logger.string).to match /unsubscribe_from_queue/
+              end
+
+            end
+          end
+        end
+
         context 'when consumer_exit_after_fail is true' do
           before { allow(RabbitFeed.configuration).to receive(:consumer_exit_after_fail).and_return(true) }