Open Stack

We are delighted to announce the release of:

oslo.messaging 5.0.0: Oslo Messaging API

This release is part of the newton release series.

With source available at:

    http://git.openstack.org/cgit/openstack/oslo.messaging

With package available at:

    https://pypi.python.org/pypi/oslo.messaging

Please report issues through launchpad:

    http://bugs.launchpad.net/oslo.messaging

For more details, please see below.

Changes in oslo.messaging 4.5.0..5.0.0
--------------------------------------

51f3b7b Updated from global requirements
a98fa8f Fixes sumulator.py signal_handler logic
4df633d Improves exception handling and logging
4275044 Implements pika thread safe connection
5708d75 Fix incorrect parameters order in assertIn call
41dd8e3 Update the RPC cast() documentation.
c903a8b Fix unstable work of cast func tests
192eeb4 [zmq] Reduce threading from python proxy
fbe6e12 Imported Translations from Zanata
5b94b4b use thread safe fnmatch
6db00c7 Refactor base interfaces
a46237f Gracefully handle missing TCP_USER_TIMEOUT
439d8ca Simulator: handle SIGINT and SIGTERM signals
159762b Updated from global requirements
62b2206 Log the unique_id in listener than msg_id
404bebc serializer: deprecate RequestContextSerializer
dfcdec3 Amqp driver send method temporary work-around
d297ad6 Updated from global requirements
a705e0b Updated from global requirements
09d5669 Allow simulator to be launched from arbitrary directory
cbd6672 [zmq] Fix cast message loss in simulator
cbaf71e Make transport_url config option secret
8afa73b Fix oslo.messaging for Mac OS X
5d7d725 Refactor driver's listener interface
9a065e3 [kafka] Do not remove kafka_client during reset
d630b64 Updated from global requirements
fbc5df6 Replace expriration_time by timer
cc1cb30 [zmq] Reduce number of connections
990d894 Move server related logic from dispatchers
3728ccc Fix typos in Oslo.messaging files
b60af23 Fix Break in Windows platforms
f8969e9 [py34] replace file() with open()
5e0bda3 Claim python3 compatability for Newton onwards
6957173 Simulator: collect error stats
e2e59a5 Simulator: make parameter wait_after_msg float
cb7bbae Update CheckForLoggingIssues hacking rule from keystone
38b907a Support python3 in simulator.py
2fb5ad9 Fix typo passend should be passenv
98bc5fc Always set all socket timeouts
dad52c1 Add a py34 functional test for rabbit
50b5468 Small fixes
bec4ef4 Use only unique topics for the Kafka driver
1385df6 [zmq] Refactoring consumer side
d3fedf8 [Kafka] Ensure a topics before consume messages
0aca222 Fix problems during unstable network
89bc0e6 Missing version parameter in can_send_version()
b6a8d51 Bump rabbit_transient_queues_ttl to 30 mins
0f58e23 Explicitly exclude tests from bandit scan
fb73297 Fix Notification listener blocking behavior
f2f2d07 Pika: fix sending fanout messages
bb4121a Revert "Ensure the json result type is bytes on Python 3"
6d2d1b2 Replace deprecated LOG.warn with LOG.warning
5588279 Simulator: store results in JSON format
84109fe Simulator: calculate message latency statistics
f42d886 Fix the driver shutdown/failover logic
0774b5c Always delete exc_info tuple, even if reply fails
33f1a3b Do not leak Listeners on failover
37c0db5 Simulator: always use random messages for time-bound tests
4e4caf6 Fallback if git is absent
97385ef Simulator: implement own random generator instead of scipy
d2496c3 Simulator: fix batch-notify-server command
0de6bd6 Work with kombu from upstream
97655c1 Fail quickly if there on bad password
76ab2c4 [zmq] Dynamic port range is ignored
c721265 [zmq] Implement Response and Envelope classes
71450fa [kafka] Use notification priority
681f631 Make simulator more asynchronous
89cc47e Adds exhange declaration on sender's side
a95035c Updated from global requirements
bd81d09 Ensure the json result type is bytes on Python 3
8dfc064 test: Don't test message's reply timeout

Diffstat (except docs and test files)
-------------------------------------

oslo_messaging/_cmd/zmq_broker.py                  |  42 --
oslo_messaging/_cmd/zmq_proxy.py                   |  76 +++
oslo_messaging/_drivers/amqpdriver.py              |  29 +-
oslo_messaging/_drivers/base.py                    | 161 +++++-
oslo_messaging/_drivers/impl_fake.py               |  13 +-
oslo_messaging/_drivers/impl_kafka.py              |  32 +-
oslo_messaging/_drivers/impl_pika.py               | 174 ++++--
oslo_messaging/_drivers/impl_rabbit.py             |  79 ++-
oslo_messaging/_drivers/impl_zmq.py                |  29 +-
.../_drivers/pika_driver/pika_commons.py           |  47 ++
.../_drivers/pika_driver/pika_connection.py        | 497 ++++++++++++++++
oslo_messaging/_drivers/pika_driver/pika_engine.py | 272 +++++----
.../_drivers/pika_driver/pika_listener.py          |  72 +--
.../_drivers/pika_driver/pika_message.py           |  98 ++--
oslo_messaging/_drivers/pika_driver/pika_poller.py | 415 ++++++++------
.../_drivers/protocols/amqp/controller.py          | 233 +++++---
oslo_messaging/_drivers/protocols/amqp/driver.py   |  62 +-
.../_drivers/protocols/amqp/drivertasks.py         |   7 +-
.../_drivers/protocols/amqp/eventloop.py           |  23 +-
.../_drivers/zmq_driver/broker/zmq_base_proxy.py   |  50 --
.../_drivers/zmq_driver/broker/zmq_broker.py       |  78 ---
.../_drivers/zmq_driver/broker/zmq_proxy.py        |  80 +++
.../_drivers/zmq_driver/broker/zmq_queue_proxy.py  | 120 +++-
.../publishers/dealer/zmq_dealer_call_publisher.py |  51 +-
.../publishers/dealer/zmq_dealer_publisher.py      |  77 ++-
.../dealer/zmq_dealer_publisher_proxy.py           |  67 +++
.../client/publishers/zmq_pub_publisher.py         |  21 +-
.../client/publishers/zmq_publisher_base.py        |  36 +-
.../_drivers/zmq_driver/client/zmq_client.py       |  10 +-
.../_drivers/zmq_driver/client/zmq_envelope.py     |  81 +++
.../_drivers/zmq_driver/client/zmq_request.py      |  17 +-
.../_drivers/zmq_driver/client/zmq_response.py     |  70 +++
.../_drivers/zmq_driver/matchmaker/base.py         |  39 ++
.../zmq_driver/matchmaker/matchmaker_redis.py      |  12 +-
.../_drivers/zmq_driver/poller/green_poller.py     |  37 +-
.../_drivers/zmq_driver/poller/threading_poller.py |  14 +-
.../server/consumers/zmq_consumer_base.py          |  64 +--
.../server/consumers/zmq_pull_consumer.py          |  14 -
.../server/consumers/zmq_router_consumer.py        |  23 +-
.../server/consumers/zmq_sub_consumer.py           |  73 +--
.../zmq_driver/server/zmq_incoming_message.py      |  19 +-
.../_drivers/zmq_driver/server/zmq_server.py       |  51 +-
oslo_messaging/_drivers/zmq_driver/zmq_async.py    |  17 +-
oslo_messaging/_drivers/zmq_driver/zmq_names.py    |   1 +
oslo_messaging/_drivers/zmq_driver/zmq_poller.py   |  32 --
oslo_messaging/_drivers/zmq_driver/zmq_socket.py   |   8 +-
oslo_messaging/dispatcher.py                       |  84 +--
oslo_messaging/hacking/checks.py                   |  30 +-
.../en_GB/LC_MESSAGES/oslo_messaging-log-error.po  |   8 +-
.../en_GB/LC_MESSAGES/oslo_messaging-log-info.po   |   8 +-
.../LC_MESSAGES/oslo_messaging-log-warning.po      |   8 +-
.../es/LC_MESSAGES/oslo_messaging-log-error.po     |   8 +-
oslo_messaging/locale/oslo_messaging-log-error.pot |  22 +-
oslo_messaging/locale/oslo_messaging-log-info.pot  |  14 +-
.../locale/oslo_messaging-log-warning.pot          |  13 +-
oslo_messaging/locale/oslo_messaging.pot           |  28 -
oslo_messaging/notify/_impl_routing.py             |   4 +-
oslo_messaging/notify/dispatcher.py                | 174 +++---
oslo_messaging/notify/listener.py                  |  89 ++-
oslo_messaging/notify/notifier.py                  |   1 +
oslo_messaging/rpc/client.py                       |  13 +-
oslo_messaging/rpc/dispatcher.py                   |  48 +-
oslo_messaging/rpc/server.py                       |  54 +-
oslo_messaging/serializer.py                       |   4 +
oslo_messaging/server.py                           |  72 ++-
oslo_messaging/transport.py                        |  12 +-
requirements.txt                                   |   6 +-
setup-test-env-zmq.sh                              |   4 +-
setup.cfg                                          |   6 +-
test-requirements.txt                              |   4 +-
tools/simulator.py                                 | 623 ++++++++++++++-------
tox.ini                                            |   8 +-
92 files changed, 3731 insertions(+), 2295 deletions(-)


Requirements updates
--------------------

diff --git a/requirements.txt b/requirements.txt
index 662a699..f4e7a66 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -8,2 +8,2 @@ futurist>=0.11.0 # Apache-2.0
-oslo.config>=3.4.0 # Apache-2.0
-oslo.context>=0.2.0 # Apache-2.0
+oslo.config>=3.9.0 # Apache-2.0
+oslo.context>=2.2.0 # Apache-2.0
@@ -15 +15 @@ oslo.i18n>=2.1.0 # Apache-2.0
-stevedore>=1.5.0 # Apache-2.0
+stevedore>=1.9.0 # Apache-2.0
diff --git a/test-requirements.txt b/test-requirements.txt
index 7f22248..dcbf4b7 100644
--- a/test-requirements.txt
+++ b/test-requirements.txt
@@ -9 +9 @@ discover # BSD
-fixtures>=1.3.1 # Apache-2.0/BSD
+fixtures<2.0,>=1.3.1 # Apache-2.0/BSD
@@ -41 +41 @@ pyngus>=2.0.0 # Apache-2.0
-bandit>=0.17.3 # Apache-2.0
+bandit>=1.0.1 # Apache-2.0