lib/phobos/actions/process_message.rb in phobos-1.7.0 vs lib/phobos/actions/process_message.rb in phobos-1.7.1

@@ -49,10 +49,10 @@
       end
 
       private
 
       def force_encoding(value)
-        @listener.encoding ? value.force_encoding(@listener.encoding) : value
+        @listener.encoding ? value&.force_encoding(@listener.encoding) : value
       end
 
       def process_message(payload)
         instrument('listener.process_message', @metadata) do
           handler = @listener.handler_class.new