Class: Phobos::Producer::ClassMethods::PublicAPI

Inherits:
Object
  • Object
show all
Defined in:
lib/deimos/monkey_patches/phobos_producer.rb

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

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

:nodoc:



32
33
34
35
 
# File 'lib/deimos/monkey_patches/phobos_producer.rb', line 32

def async_publish(topic, payload, key=nil, partition_key=nil)
  async_publish_list([{ topic: topic, payload: payload, key: key,
                        partition_key: partition_key }])
end

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

:nodoc:



26
27
28
29
 
# File 'lib/deimos/monkey_patches/phobos_producer.rb', line 26

def publish(topic, payload, key=nil, partition_key=nil)
  publish_list([{ topic: topic, payload: payload, key: key,
                  partition_key: partition_key }])
end