Contents

# encoding: utf-8
require 'ffi-rzmq'

class ZeroMQClient

  attr_reader :addr, :port, :context, :requester

  def initialize(addr, port)
    @addr   = addr
    @port   = port
    @context = ZMQ::Context.new(1)
    @requester = context.socket(ZMQ::PULL)
    @requester.bind("tcp://#{addr}:#{port}")
  end

  def recv
    s = ''
    @requester.recv_string s
    s
  end

  def close
    @requester.close
    @context.terminate
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
logstash-output-zeromq-3.1.3	spec/support/client.rb
logstash-output-zeromq-3.1.2	spec/support/client.rb
logstash-output-zeromq-3.1.1	spec/support/client.rb
logstash-output-zeromq-3.0.0	spec/support/client.rb
logstash-output-zeromq-2.1.0	spec/support/client.rb