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