Class: Heller::Producer

Inherits:
Object
  • Object
show all
Defined in:
lib/heller/producer.rb

Instance Method Summary collapse

Constructor Details

#initialize(broker_list, options = {}) ⇒ Producer

Returns a new instance of Producer.



5
6
7
 
# File 'lib/heller/producer.rb', line 5

def initialize(broker_list, options = {})
  @producer = create_producer(options.merge(brokers: broker_list))
end

Instance Method Details

#disconnect ⇒ Object Also known as: close 



13
14
15
 
# File 'lib/heller/producer.rb', line 13

def disconnect
  @producer.close
end

#push(messages) ⇒ Object 



9
10
11
 
# File 'lib/heller/producer.rb', line 9

def push(messages)
  @producer.send(ArrayList.new(Array(messages)))
end