lib/rabbit_feed/producer.rb in rabbit_feed-2.1.1 vs lib/rabbit_feed/producer.rb in rabbit_feed-2.1.2
- old
+ new
@@ -7,10 +7,10 @@
def publish_event name, payload
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 = Event.new metadata, payload, event_definition.schema, event_definition.sensitive_fields
ProducerConnection.publish event.serialize, (options name, timestamp)
event
end
private