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