Class: Sbmt::KafkaProducer::OutboxProducer

Inherits:

BaseProducer

Object
BaseProducer
Sbmt::KafkaProducer::OutboxProducer

show all

Defined in:: lib/sbmt/kafka_producer/outbox_producer.rb

Constant Summary

Constants inherited from BaseProducer

BaseProducer::MSG_SUCCESS

Instance Method Summary collapse

#call(outbox_item, payload) ⇒ Object

Methods inherited from BaseProducer

#async_publish, #async_publish!, #sync_publish, #sync_publish!

Instance Method Details

#call(outbox_item, payload) ⇒ `Object`



6
7
8

# File 'lib/sbmt/kafka_producer/outbox_producer.rb', line 6

def call(outbox_item, payload)
  sync_publish!(payload, **outbox_item.options)
end