added more logger messages

ideacrew · Feb 3, 2025 · a5fcf66 · a5fcf66
1 parent c78a55e
commit a5fcf66
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/event_source/protocols/amqp/bunny_queue_proxy.rb b/lib/event_source/protocols/amqp/bunny_queue_proxy.rb
@@ -180,6 +180,9 @@ def decode_payload(payload)
           if output.success?
             output.value!
           else
+            logger.error '*' * 40
+            logger.error payload.encoding if payload.respond_to?(:encoding)
+            logger.error payload.inspect
             logger.error "Failed to decode message \n  due to: #{output.failure} \n  payload: #{payload}"
             raise EventSource::Error::PayloadDecodeError, output.failure
           end

diff --git a/spec/event_source/protocols/amqp/bunny_queue_proxy_spec.rb b/spec/event_source/protocols/amqp/bunny_queue_proxy_spec.rb
@@ -408,6 +408,9 @@
         end
 
         it 'logs the error and raises a PayloadDecodeError' do
+          expect(instance.logger).to receive(:error).with('*' * 40)
+          expect(instance.logger).to receive(:error).with(payload.encoding) if payload.respond_to?(:encoding)
+          expect(instance.logger).to receive(:error).with(payload.inspect)
           expect(instance.logger).to receive(:error).with("Failed to decode message \n  due to: #{failure_message} \n  payload: #{payload}")
           expect do
             instance.decode_payload(payload)