Method: Redborder::KafkaNotifier.send

Defined in:
lib/kafka_notifier.rb

.send(topic, key, message) ⇒ Object 



46
47
48
49
50
 
# File 'lib/kafka_notifier.rb', line 46

def self.send(topic, key, message)
  start if message_queue.nil?
  strmsg = JSON.generate(message) if message.is_a? Hash
  message_queue << Poseidon::MessageToSend.new(topic, strmsg, key)
end