Class: Liam::Producer

Inherits:

Object

• Object
• Liam::Producer

Extended by:

Forwardable

Includes:

Common

Defined in:

lib/liam/producer.rb

Constant Summary

UNSUPPORTED_MESSAGE_ERROR =

'Unsupported message argument'

UNSUPPORTED_TOPIC_ERROR =

'Unsupported topic argument'

Constants included from Common

Common::CONFIG_FILE

Class Method Summary

• .message(*args) ⇒ Object

Instance Method Summary

• #initialize(message:, options: {}, topic:) ⇒ Producer constructor

  A new instance of Producer.

Methods included from Common

#client_options, #credentials, #env_credentials

Constructor Details

#initialize(message:, options: {}, topic:) ⇒ Producer

Returns a new instance of Producer.

# File 'lib/liam/producer.rb', line 17

def initialize(message:, options: {}, topic:)
  @message = message
  @options = options
  @topic = topic
end

Class Method Details

.message(*args) ⇒ Object

# File 'lib/liam/producer.rb', line 23

def self.message(*args)
  new(*args).send(:execute)
end