Hi @faithful-ostrich @courteous-yorkshire Issue has been fixed.
The code in the other thread includes the fix for the constructor; the above misses the send method.
@courteous-yorkshire @faithful-ostrich Is there any option to clear all queue using terminal command ?
@courteous-yorkshire @faithful-ostrich amqp receiving the log successfully. But the looping condition is working . same log inserted ti amqp multiple times. How to solve this issue ?
**error shows **
Dec 22 09:34:34 development.domain.com kumod[1233502]: 2023-12-22T09:34:34.012754Z DEBUG localset-1 maintain_named_queue: kumod::queue: maintaining queue amqp which has 2 entries Dec 22 09:33:34 development.domain.com kumod[1233502]: 2023-12-22T09:33:34.246829Z DEBUG localset-7 kumod::ready_queue: Error in Dispatcher::run for unspecified->amqp@lua:make.amqp: deliver_message: error converting Lua nil to String (expected string or n> Dec 22 09:33:34 development.domain.com kumod[1233502]: 2023-12-22T09:33:34.246758Z DEBUG localset-7 run{name="unspecified->amqp@lua:make.amqp" queue_name="amqp" mx=None queue_config=ConfigHandle { inner: Inner { config: Mutex { data: QueueConfig { retry_i> Dec 22 09:33:34 development.domain.com kumod[1233502]: 2023-12-22T09:33:34.246691Z DEBUG localset-7 run{name="unspecified->amqp@lua:make.amqp" queue_name="amqp" mx=None queue_config=ConfigHandle { inner: Inner { config: Mutex { data: QueueConfig { retry_i> lines 1-11/11 (END)
Actually, the code in the other thread was missing a return value in the case of a successful send, here is what I use as a return value:
if result.status == "Ack" or result.status == "NotRequested" then
-- Success
return result.status
end
Ok @courteous-yorkshire Thanks