When a caller msg doesn't exists anymore but a reply is ready for it.
amqp driver drop the whole message into a logging.warn. That can be a
bit huge in some case.
This change just writes the message id to the WARN level and put the queues
and the messages into the debug level.
Change-Id: Ibcc6b066171cdea48f102ca1bd85f81c639fbbb5
Add pbr to the list of installation requirements so that it is installed
via pip before this library is installed, instead of with easy_install.
This avoids issues like Bug #1384919, and ensures that projects that use
this library as a dependency are properly installed.
Change-Id: I6c155370dbd01fe4748d5137bdf288e8d3e1a67e
Add driver independent functional tests of the messaging API
The url used to select (and configure) the driver is specified as an
environment variable named TRANSPORT_URL.
Change-Id: I867001a15ffaca06ae831cfd0240ed3397bf6503
In case of the call()er die, the queue used to reply must be
automatically deleted, otherwise they will never been deleted.
This is done in the same way as the rabbit drivers does,
by enabling auto-delete on this queue.
Change-Id: Ib01981d704b8849e0115791ff90fbb74cbac421f
Closes-Bug: #1374519
If you don't close the AMQP connection, then the connection
remains open and the next time when the messages are sent on
the listening topic, then some of the messages will not be processed
as there is no dispatcher running to process the message.
Closes-Bug: #1335086
Change-Id: I1f39eedf1500b6b6209ae0222f32e08e304895e0
This helps in circumstances where the only stacktrace visible
is on the target side (e.g. due to cast or fanout operations)
and without the method information is difficult to root cause
what is going on.
Change-Id: I070ecda4d56186fcda8e8bfc49bf723928998393
Closes-bug: #1340277
In _safe_log it uses recursive closure. The gc can not free stack for
this recursive closure for cycle-reference. So cut down the cycle
to fix it.
Resolved-bug: #1365892
Change-Id: I05fbd7091b886344d76b172a5ad66d9225599d69
The group for options of amqp driver have been moved
in d753b030c681de16b6f2451900cd6370c5068c95
This change adds the deprecated group for this options.
Change-Id: Id97a3fcfdaa5d231be217d6191792a538964b109