Sha256: 873a35efec7639d205836fb64a92a3295023f5c5251c33e5664dcb1dae067330
Contents?: true
Size: 592 Bytes
Versions: 27
Compression:
Stored size: 592 Bytes
Contents
module LogjamAgent
class Receiver
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
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
end
end
Version data entries
27 entries across 27 versions & 1 rubygems