lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.3.4 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.3.5
- old
+ new
@@ -63,10 +63,16 @@
end
end
end
def message_info_fragment(message)
- "(#{message.object_id}): #{message.subject} : #{message.body.inspect}"
+ "(#{message.guid}): #{message.subject} : #{message_info_arguments(message).inspect}"
+ end
+
+ def message_info_arguments(message)
+ message.body.dup.tap { |m|
+ m.delete('guid')
+ }
end
def handle_next_queue_item
queue.pop do |message|
begin