class LogjamAgent::Receiver

Public Class Methods

new() click to toggle source
# File lib/logjam_agent/receiver.rb, line 3
def initialize
  @socket = ZMQForwarder.context.socket(ZMQ::ROUTER)
  @socket.setsockopt(ZMQ::RCVTIMEO, 100)
  if @socket.bind("inproc://app") < 0
    raise "ZMQ error on binding: #{ZMQ::Util.error_string}"
  end
  at_exit { @socket.close }
end

Public Instance Methods

receive() click to toggle source
# File lib/logjam_agent/receiver.rb, line 12
def receive
  answer_parts = []
  if @socket.recv_strings(answer_parts) < 0
    raise "ZMQ error on receiving: #{ZMQ::Util.error_string}"
  end
  answer_parts.shift
  answer_parts[2] = JSON.parse(answer_parts[2])
  answer_parts
end