lib/rabbit_feed/producer.rb in rabbit_feed-2.1.5 vs lib/rabbit_feed/producer.rb in rabbit_feed-2.3.0

@@ -8,10 +8,12 @@
       raise (Error.new 'Unable to publish event. No event definitions set.') unless event_definitions.present?
       event_definition = event_definitions[name] or raise (Error.new "definition for event: #{name} not found")
       timestamp        = Time.now.utc
       metadata         = (metadata event_definition.version, name, timestamp)
       event            = Event.new metadata, payload, event_definition.schema, event_definition.sensitive_fields
-      ProducerConnection.publish event.serialize, (options name, timestamp)
+      RabbitFeed.log.info {{ event: :publish_start, metadata: event.metadata }}
+      ProducerConnection.instance.publish event.serialize, (options name, timestamp)
+      RabbitFeed.log.info {{ event: :publish_end, metadata: event.metadata }}
       event
     end
 
     private