This patch proposes to allow TransportURLs to have query parameters
with driver-specific options which may override corresponding
values from a static configuration. As an example, the patch
implements this possibility in the pika driver. If the idea is
approved, it will be possible to also implement it in the other
drivers.
Change-Id: Ibb7e13b4509fde035a3c334cde9bc4c498f92140
* Connect endpoints to a newcomer router-proxy.
* Add TTL expriation to all redis keys.
* Update redis periodically from routers.
Change-Id: I0f73cc47f32f95bd4bb7e7f144adba491e94a346
There is a redundant for in help info of
default_notification_exchange, delete it.
Change-Id: I258bfe7fbc06f45398f0800ac69159dc313f2ff2
Closes-Bug: #1589381
If using the router proxy we need to be able to
dispatch all types of messages over the routers,
not limiting them to direct types only.
Also added fanout possibility to do on a client-side,
so we can reduce latency on a proxy, and not using
pub-sub for fanout when we don't want it.
Change-Id: Ic88c306c1d386dd582cbccfc5719fba5668a9db8
This method is called on each message publishing and as shows
profiling (CProfile), the method is time-consuming, because it
uses pkg_resources module.
As we uses kombu>=3.0.25 since Mitaka, we no longer need in it.
Change-Id: I00723a3de81249946a8220ad47129f059d6d544f
Randomize the initial selection of the host list for amqp 1.0 connection
attempts.
This patch:
* randomizes initial index
* updates failover unit tests
Change-Id: Iab5ae684a2cd8ec0c6d0c59ffffde5eb5baf883b
The patch fixes some problems arised after merging the previous
patch which this patch depends on.
Change-Id: If38edec19f9bffc8ac54818b2536243a9edaf7e8
Depends-On: I608c828123b196099933d16801f8ce7d9dd3a079
Closes-Bug: #1584889
This change starts the deprecation process for the transport aliases.
The first step is deprecate this one cycle. To ensure deployer have
updated they configuration during Newton Then in Octacia we will deprecate
'aliases' kwargs of transportURL() and get_transport() for consuming
application.
Related-bug: #1424728
Change-Id: I314cefa5fb1803fa7e21e3e34300e5ced31bba89
This patch removes log_failure argument from the function
serialize_remote_exception and from driver implementations
using it (because it is never used and always defaults to True)
and prevents error logging in this function (because these errors
are already logged by servers while processing incoming messages).
Change-Id: Ic01bb11d6c4f018a17f3219cdbd07ef4d30fa434
Closes-Bug: 1580352
At that moment kafka driver can use only url with one "host:port"
for the bootstrap server defining, but kafka client supports
set of host:port adresses: "host1:port1,host2:port2", ... .
This patch implement this functional in kafka driver for the better HA.
List self.hostaddrs stores strings "host:port" of Connection.
It collects from self.url.hosts
Change-Id: I5eece66ca6bd069a0df8c8629b4ac815f69a7c7d
Closes-Bug: #1572017
Redeclare queues on 'Basic.consume: (404) no queue' exception
and enable by default consumer declaration with nowait=False
in order to wait for a broker response.
Change-Id: I99f2bc858dbc7c18a2f328ee26f39105ed17cee3
Closes-Bug: #1581148
