Class: Phobos::Producer::PublicAPI

Inherits:

Object

show all

Instance Method Summary collapse



12
13
14

# File 'lib/phobos/producer.rb', line 12

def initialize(host_obj)
  @host_obj = host_obj
end



20
21
22

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

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



34
35
36

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

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



16
17
18

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

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



30
31
32

# File 'lib/phobos/producer.rb', line 30

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