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'

SKIPPED_MESSAGE =

'The message was skipped by the configuration of the environment'

Constants included from Common

Common::CONFIG_FILE

Class Method Summary

• .message(**args) ⇒ Object

Instance Method Summary

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

  A new instance of Producer.

Methods included from Common

#client_options, #credentials, #env_credentials

Constructor Details

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

Returns a new instance of Producer.

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

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

Class Method Details

.message(**args) ⇒ Object

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

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