mengz0 / amqp Goto Github PK

Hi,

Thanks for your script , its very useful for me...

I need some example ( order of function usage) for ,
* declare the exchange
* bind the exchange
* declare the queue
* bind the queue
* set the callback function.

I hope u will help me..

Thank you.

Hi,

Would it be possible to upgrade the protocol to 1. and use Co routine API in order to make it usable with OpenResty ? (tall list, I know) but I thought I would ask.

using the '' (default exchange) is not possible:

The fix is to (as per the RabbitMQ documentation) not do the the binding then exchange == '''

Proposed fix is :

439 if ctx.opts.exchange ~= "" then
440 local res, err = amqp.queue_bind(ctx)
441 if not res then
442 logger.error("[prepare_to_consume] queue_bind failed: " .. err)
443 return nil, err
444 end
445 end

Could this is be made into a luarocks package please ?

The code that tries to detect the bitops functions is wrong and does not work.

if should test for luajit or 5.2 and 5.3 and it present not do any of the operation
mentioned or depend on the bitops library and just rename the function name if necessary

Is it possible to have some documentation on how to use this library more than the 2 samples
use case you have already ?

Hello! Do you plan to implement AMQP 1.0 support?

no_ack and durable are not transmitted correctly to the RabbitMQ server.

Encoding seems to not be done correctly in the frame.lua

In your luarocks package luajit detection does not seem to work
and the provided extra function to replace bitops also fails

Actually i want to use it as a job queue so I put my operation into the amqp:consume() function.when a element inserted into the queue , it is consumed by amqp:consume() and I will process it.But I want send a response to the sender that task finished.I am very much new in lua and amqp. Can you please suggest any solution which will serve my purpose?

This library works really well in my application and then I occasionally get an error back, always seems to occur on big messages. In my Lua code, closing and re-opening the connection doesn't resolve the problem, and I just get the same error message back.

On the Lua side, error is...

4	[amqp.publish] failed: [wire_body_frame]closed	

In the RabbitMQ logs I see...

=ERROR REPORT==== 8-May-2018::16:23:14 ===
Error on AMQP connection <0.20779.0> (127.0.0.1:53934 -> 127.0.0.1:5672, vhost: '/', user: 'guest', state: running), channel 1:
operation none caused a connection exception frame_error: "type 3, all octets = <<>>: {frame_too_large,24219917,131064}"

In this case, the message body is length 24219917 i.e. around 23MB.

lua /usr/share/lua/5.1/amqp.lua
lua: /usr/share/lua/5.1/amqp.lua:509: unexpected symbol near ':'

installed using luarocks today

running on CentOS 6

lua -v
Lua 5.1.4  Copyright (C) 1994-2008 Lua.org, PUC-Rio