@ -38,19 +38,19 @@ See [zmq_close(3)](http://api.zeromq.org/zmq_close.html).
s:close()
## setsockopt
## setopt
Sets a specified option on a ØMQ socket.
See [zmq_setsockopt(3)](http://api.zeromq.org/zmq_setsockopt.html).
s:setsockopt(option, optval)
s:setopt(option, optval)
## getsockopt
## getopt
Gets a specified option of a ØMQ socket.
See [zmq_getsockopt(3)](http://api.zeromq.org/zmq_getsockopt.html).
s:getsockopt(option)
s:getopt(option)
## bind
@ -27,7 +27,7 @@ s:bind("tcp://lo:5555")
while true do
local query = s:recv()
while s:getsockopt(zmq.RCVMORE) == 1 do
while s:getopt(zmq.RCVMORE) == 1 do
query = query .. s:recv()
end
print(string.format("Received query: '%s'", query))
@ -22,7 +22,7 @@ require("zmq")
local ctx = zmq.init(1, 1, 0)
local s = ctx:socket(zmq.SUB)
s:setsockopt(zmq.SUBSCRIBE, "")
s:setopt(zmq.SUBSCRIBE, "")
s:connect("tcp://localhost:5555")
local msg = s:recv()
@ -31,7 +31,7 @@ local message_count = tonumber(arg[3])
local ctx = zmq.init(1, 1)
s:setsockopt(zmq.SUBSCRIBE, "");
s:setopt(zmq.SUBSCRIBE, "");
s:bind(bind_to)
@ -306,8 +306,8 @@ static const luaL_reg ctxmethods[] = {
static const luaL_reg sockmethods[] = {
{"close", Lzmq_close},
{"setsockopt", Lzmq_setsockopt},
{"getsockopt", Lzmq_getsockopt},
{"setopt", Lzmq_setsockopt},
{"getopt", Lzmq_getsockopt},
{"bind", Lzmq_bind},
{"connect", Lzmq_connect},
{"send", Lzmq_send},