lib/dirty_pipeline/redis/queue.rb in dirty_pipeline-0.8.3 vs lib/dirty_pipeline/redis/queue.rb in dirty_pipeline-0.9.0

@@ -50,10 +50,12 @@
         JSON.dump(
           "evid" => event.id,
           "txid" => event.tx_id,
           "transit" => event.transition,
           "args" => event.args,
+          "source" => event.source,
+          "destination" => event.destination,
         )
       end
 
       def unpack(packed_event)
         return unless packed_event
@@ -62,9 +64,11 @@
           data: {
             "uuid" => unpacked_event["evid"],
             "transaction_uuid" => unpacked_event["txid"],
             "transition" => unpacked_event["transit"],
             "args" => unpacked_event["args"],
+            "source" => unpacked_event["source"],
+            "destination" => unpacked_event["destination"]
           }
         )
       end
 
       def events_queue_key