Class: Phobos::Producer::PublicAPI

Inherits:
Object
  • Object
show all
Defined in:
lib/phobos/producer.rb

Instance Method Summary collapse

Constructor Details

#initialize(host_obj) ⇒ PublicAPI

Returns a new instance of PublicAPI.



14
15
16
 
# File 'lib/phobos/producer.rb', line 14

def initialize(host_obj)
  @host_obj = host_obj
end

Instance Method Details

#async_publish(topic, payload, key = nil, partition_key = nil) ⇒ Object 



22
23
24
 
# File 'lib/phobos/producer.rb', line 22

def async_publish(topic, payload, key = nil, partition_key = nil)
  class_producer.async_publish(topic, payload, key, partition_key)
end

#async_publish_list(messages) ⇒ Object 



36
37
38
 
# File 'lib/phobos/producer.rb', line 36

def async_publish_list(messages)
  class_producer.async_publish_list(messages)
end

#publish(topic, payload, key = nil, partition_key = nil) ⇒ Object 



18
19
20
 
# File 'lib/phobos/producer.rb', line 18

def publish(topic, payload, key = nil, partition_key = nil)
  class_producer.publish(topic, payload, key, partition_key)
end

#publish_list(messages) ⇒ Object

Parameters:

  • messages (Array(Hash(:topic, :payload, :key))) —

    e.g.: [

    { topic: 'A', payload: 'message-1', key: '1' },
{ topic: 'B', payload: 'message-2', key: '2' }

    ]



32
33
34
 
# File 'lib/phobos/producer.rb', line 32

def publish_list(messages)
  class_producer.publish_list(messages)
end