lib/0mq/socket.rb in 0mq-0.1.1 vs lib/0mq/socket.rb in 0mq-0.1.2
- old
+ new
@@ -10,9 +10,10 @@
def initialize(type, opts={})
@context = opts.fetch :context, ZMQ::DefaultContext
@type = type
@ptr = LibZMQ.zmq_socket @context.ptr, @type
+ ZMQ.error_check true if @ptr.null?
@msgptr = FFI::MemoryPointer.new LibZMQ::Message.size, 1, false
ObjectSpace.define_finalizer self,
self.class.finalizer(@socket, Process.pid)