module Kafka::Lite
Constants
- CONSUMER_REGISTRY
- PRODUCER_QUEUE
- VERSION
Public Instance Methods
deliver_message(msg)
click to toggle source
# File lib/kafka_lite.rb, line 47 def deliver_message msg PRODUCER_QUEUE.push msg end
send(event)
click to toggle source
# File lib/kafka_lite.rb, line 43 def send event deliver_message event.to_json end