The usage of assertEqual(True/False, ***) should be changed
to a meaningful format of assertTrue/False(***).
Change-Id: Idda812a34be8aa53654d6791eac47028339d3cb7
Closes-Bug:#1512207
kombu has already made a conversion from seconds to milliseconds,
so we do not need to do it again.
Closes-Bug: #1531148
Change-Id: Ia4478f15f1980a93a53f7e1e6570f68aeec75c69
In this change PUB/SUB pattern was used for notifications.
Reduced useless split to direct/fanout notifications.
All notifications are fanout by default.
Change-Id: I232c093af76757dc6fc5e942d47f0473877f9efa
Closes-Bug: #1529845
RPC server uses direct_send method to send replies.
The method sets "passive" flag on an exchange.
Thus auto_declare doesn't bring any good there, but it costs
an additional "exchange.declare" call to RabbitMQ.
simulator.py RPC tests shows that a perfomance gain is ~7%
Change-Id: Ia9f5f9f52c6cb324eca4ca6a63e80d604ddefa23
* Avoid string concatenation during logging, especially
when logging level is disabled.
* Initialize the Randomized strings we will be using
as payloads *before* we start sending the messages
as the string creation takes time and reduces
throughput
Change-Id: I546229fe7ade95572e11bcda95a587228d84bc28
Method import_zmq returns None if can't import zmq module.
For runtime code, an ImportError is raised, and for tests,
a skip message "zmq not available" is sent, so it's unnecessary
to log error which shows up in other projects' unit test logs.
Co-Authored-By: Oleksii Zamiatin <ozamiatin@mirantis.com>
Change-Id: Iebf15042f45da56eb633a0a70822c487dc72c884
Closes-Bug: #1528415
Also small mistakes were fixed,
msg_id, unique_id and reply_q fields were
moved to corresponding AMQP properties
Change-Id: I5147c35c1a2ce0205e08ca81db164a3cc879fb0a
In this change PUB-SUB pipeline was added
and used for CAST-Fanout pattern.
Added 2 new options:
* use_pub_sub - configures the driver to use
PUB/SUB if True, fallbacks to DEALER/ROUTER implementation
otherwise.
PUB/SUB implementation is assumed to be always used with proxy.
* direct_over_proxy - specifies to use proxy with direct patterns
(CALL,CAST). This option is in replace of zmq_use_broker.
Latter is meaningless in context of PUB/SUB architecture,
so renamed.
Change-Id: I7c02d4d62632293941bc0d9d947e5362a5317db6
Closes-Bug: #1515185
When a client is gone (died/restart) and somes replies cannot be sent because
the the exchange of this client will never comeback. We log one message per
reply every 0.25 messages during 60 seconds. When the only useful log
is the one where we decide to drop this replies.
This change moves the less important message to debug level.
Change-Id: I508787c0db4dcec2c0027b89eb4e65c4f98022b9
Related-bug: #1524418
This patch removes `MANIFEST.in` file as pbr generates a sensible
manifest from git files and some standard files and it removes
the need for an explicit `MANIFEST.in` file.
Change-Id: I487247ec1b4f692c62e1794dbfede5b4e2924593
When AMQPDestinationNotFound is raised, we must not
call the error_callback method. The exception is logged
only if needed in upper layer (amqpdriver.py).
Related-bug: #1524418
Change-Id: Ic1ddec2d13172532dbaa572d04a4c22c97ac4fe7
Also this patch:
1) fixed import's order
2) removes PikaDriverCompatibleWithOldRabbit
(tests, show that after retry implementation all works fine)
Change-Id: Ib34f6db569cadb5c27d8865f13ba32ef9a6c73e9
