lib/eventsimple/event.rb in eventsimple-1.3.3 vs lib/eventsimple/event.rb in eventsimple-1.4.0

- old
+ new

@@ -12,12 +12,12 @@ self._aggregate_klass = aggregate_klass class_attribute :_aggregate_id self._aggregate_id = aggregate_id - class_attribute :_outbox_mode - class_attribute :_outbox_concurrency + class_attribute :_outbox_enabled + class_attribute :_consumer_group_size class_attribute :_on_invalid_transition self._on_invalid_transition = ->(error) { raise error } self.inheritance_column = :type @@ -159,10 +159,10 @@ with_retries(args) { super } end end def with_locks(&block) - if _outbox_mode + if _outbox_enabled base_class.with_advisory_lock(base_class.name, { transaction: true }, &block) else yield end end