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