ffi-rzmq socket monitor test

monitor.rb

require 'ffi-rzmq'

class Event
  class Layout < FFI::Struct
    layout :event, :int,
           :data, ZMQ::LibZMQ::EventData
  end

  def initialize(msg)
    @data = Layout.new(msg.data)
  end

  def event
    @data[:event]
  end

  def data
    @data[:data]
  end
end 

context = ZMQ::Context.new
socket = context.socket ZMQ::DEALER
ZMQ::LibZMQ.zmq_socket_monitor(socket.socket, "inproc://monitor.dealer", 1023)
listener = context.socket ZMQ::PAIR
listener.connect("inproc://monitor.dealer")
socket.bind("tcp://127.0.0.1:58000")
m = ZMQ::Message.new; listener.recvmsg m
e = Event.new(m)
puts e.event
puts e.data.addr

require 'rubygems'
require 'ffi-rzmq'
context = ZMQ::Context.new
socket = context.socket ZMQ::DEALER
#rc = ZMQ::LibZMQ.zmq_socket_monitor(socket, "inproc://monitor.dealer", 0)
rc = ZMQ::LibZMQ.zmq_socket_monitor(socket.socket, "inproc://monitor.dealer", 0)
p rc

require 'rubygems'
require 'ffi-rzmq'

context = ZMQ::Context.new
socket = context.socket ZMQ::DEALER
ZMQ::LibZMQ.zmq_socket_monitor(socket.socket, "inproc://monitor.dealer", 1023)
listener = context.socket ZMQ::PAIR
listener.connect("inproc://monitor.dealer")
socket.bind("tcp://127.0.0.1:58000")
m = ZMQ::Message.new
listener.recvmsg m
e = ZMQ::LibZMQ::EventData.new(m.data)

p e