app/models/journaled/writer.rb in journaled-3.1.0 vs app/models/journaled/writer.rb in journaled-4.0.0

- old
+ new

@@ -1,11 +1,11 @@ class Journaled::Writer EVENT_METHOD_NAMES = %i( journaled_schema_name journaled_partition_key journaled_attributes - journaled_app_name + journaled_stream_name journaled_enqueue_opts ).freeze def initialize(journaled_event:) raise "An enqueued event must respond to: #{EVENT_METHOD_NAMES.to_sentence}" unless respond_to_all?(journaled_event, EVENT_METHOD_NAMES) @@ -39,10 +39,10 @@ def delivery_perform_args { serialized_event: serialized_event, partition_key: journaled_partition_key, - app_name: journaled_app_name, + stream_name: journaled_stream_name, } end def serialized_event @serialized_event ||= journaled_attributes.to_json