my lua env is lua5.1.4 ,rocketmq version is 4.2
$ vi test.lua
local Producer = require("rocketmq").Producer
local Message = require("rocketmq").Message
local producer = Producer:new('PID-XXX')
producer:set_name_server_address('127.0.0.1:9876')
producer:start()
local msg = Message:new('test')
msg:set_keys('test')
msg:set_tags('test')
msg:set_body('XXXX')
for k,v in pairs(msg) do
print(k,v)
end
local ret = producer:send_sync(msg)
print(ret.sendStatus,ret.msgId)
--ngx.say(string.format("%s,%s,%s", tonumber(ret.sendStatus),ffi.string(ret.msgId),tonumber(ret.offset))
)
producer:shutdown()
$ luajit test.lua
luajit: /usr/local/share/lua/5.1/rocketmq/producer.lua:63: bad argument #2 to 'SendMessageSync' (cannot convert 'table' to 'struct CMessage *')
stack traceback:
[C]: in function 'SendMessageSync'
/usr/local/share/lua/5.1/rocketmq/producer.lua:63: in function 'send_sync'
/root/test-rocketmq-producer.lua:16: in main chunk
[C]: at 0x00404a10
please help me check this error。and I want to know your rocketmq version and lua version。And my
my lua env is lua5.1.4 ,rocketmq version is 4.2 $ vi test.lua local Producer = require("rocketmq").Producer local Message = require("rocketmq").Message
local producer = Producer:new('PID-XXX') producer:set_name_server_address('127.0.0.1:9876') producer:start() local msg = Message:new('test') msg:set_keys('test') msg:set_tags('test') msg:set_body('XXXX') for k,v in pairs(msg) do print(k,v) end
local ret = producer:send_sync(msg) print(ret.sendStatus,ret.msgId) --ngx.say(string.format("%s,%s,%s", tonumber(ret.sendStatus),ffi.string(ret.msgId),tonumber(ret.offset)) ) producer:shutdown()
$ luajit test.lua luajit: /usr/local/share/lua/5.1/rocketmq/producer.lua:63: bad argument #2 to 'SendMessageSync' (cannot convert 'table' to 'struct CMessage *') stack traceback: [C]: in function 'SendMessageSync' /usr/local/share/lua/5.1/rocketmq/producer.lua:63: in function 'send_sync' /root/test-rocketmq-producer.lua:16: in main chunk [C]: at 0x00404a10
please help me check this error。and I want to know your rocketmq version and lua version。And my