Set HWM option to zero to override new default in zeromq 3.x

pull/47/merge
Robert G. Jakabosky 13 years ago
parent 214e2601cf
commit 8d962b4ac9

@ -31,6 +31,8 @@ local zmq = require"zmq"
local ctx = zmq.init(1) local ctx = zmq.init(1)
local s = ctx:socket(zmq.PUB) local s = ctx:socket(zmq.PUB)
-- for ZeroMQ 3.x need to change HWM option.
s:set_hwm(0)
s:connect(connect_to) s:connect(connect_to)
zmq.sleep(1) zmq.sleep(1)

@ -38,6 +38,8 @@ local child_code = [[
local ctx = zthreads.get_parent_ctx() local ctx = zthreads.get_parent_ctx()
local s = ctx:socket(zmq.PUB) local s = ctx:socket(zmq.PUB)
-- for ZeroMQ 3.x need to change HWM option.
s:set_hwm(0)
s:connect(connect_to) s:connect(connect_to)
local data = ("0"):rep(message_size) local data = ("0"):rep(message_size)

Loading…
Cancel
Save