Class: TransactionalOutbox::Producer

Inherits:

Object

• Object
• TransactionalOutbox::Producer

Extended by:

Forwardable

Defined in:

lib/transactional_outbox/producer.rb,
lib/transactional_outbox/producer/adapters.rb,
lib/transactional_outbox/producer/adapters/base.rb,
lib/transactional_outbox/producer/adapters/null.rb,
lib/transactional_outbox/producer/adapters/kafka.rb,
lib/transactional_outbox/producer/adapters/interface.rb,
lib/transactional_outbox/producer/adapters/instance_methods.rb

Defined Under Namespace

Classes: Adapters

Instance Attribute Summary

• #adapter ⇒ Object readonly

  Returns the value of attribute adapter.

Instance Method Summary

• #initialize ⇒ Producer constructor

  A new instance of Producer.

Constructor Details

#initialize ⇒ Producer

Returns a new instance of Producer.

# File 'lib/transactional_outbox/producer.rb', line 11

def initialize
  @adapter = TransactionalOutbox::Producer::Adapters.resolve(fetch_adapter).new(config.producer.connection_config)
end

Instance Attribute Details

#adapter ⇒ Object (readonly)

Returns the value of attribute adapter.

# File 'lib/transactional_outbox/producer.rb', line 9

def adapter
  @adapter
end