We are psyched to announce the release of: oslo.messaging 4.0.0: Oslo Messaging API This release is part of the mitaka 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 For more details, please see below and: http://launchpad.net/oslo.messaging/+milestone/4.0.0 Please report issues through launchpad: http://bugs.launchpad.net/oslo.messaging Changes in oslo.messaging 3.1.0..4.0.0 -------------------------------------- 1a03d7b [zmq] PUB-SUB pipeline b1039db Updated from global requirements a5d7889 Updated from global requirements 17ccb23 Move to debug a too verbose log 46daf85 Cleanup parameter docstrings 9b8980d Removes MANIFEST.in as it is not needed explicitely by PBR 3ee8696 Revert "default of kombu_missing_consumer_retry_timeout" e725994 Don't trigger error_callback for known exc 185693a Improves comment 148e838 Fix reconnection when heartbeat is missed 576e6cc Revert "serializer: deprecate RequestContextSerializer" 050024f Fix notifier options registration 185f94c notif: Check the driver features in dispatcher 4dd644a batch notification listener a1fb6b9 Updated from global requirements bdf287e creates a dispatcher abstraction 2a4f915 Remove unnecessary quote 5561a6f Fix multiline strings with missing spaces 52ccff7 Properly skip zmq tests without ZeroMQ being installed c1d0412 kombu: remove compat of folsom reply format 6ad7071 Follow the plan about the single reply message Diffstat (except docs and test files) ------------------------------------- MANIFEST.in | 13 -- oslo_messaging/_drivers/amqp.py | 12 -- oslo_messaging/_drivers/amqpdriver.py | 85 ++++------- oslo_messaging/_drivers/base.py | 31 +++- oslo_messaging/_drivers/common.py | 2 +- oslo_messaging/_drivers/impl_fake.py | 1 + oslo_messaging/_drivers/impl_kafka.py | 1 + oslo_messaging/_drivers/impl_rabbit.py | 18 ++- oslo_messaging/_drivers/impl_zmq.py | 46 +++--- oslo_messaging/_drivers/protocols/amqp/driver.py | 14 +- .../_drivers/protocols/amqp/drivertasks.py | 2 +- .../_drivers/zmq_driver/broker/zmq_queue_proxy.py | 16 +- .../publishers/dealer/zmq_dealer_call_publisher.py | 13 +- .../publishers/dealer/zmq_dealer_publisher.py | 7 + .../client/publishers/zmq_pub_publisher.py | 102 +++++++++++-- .../client/publishers/zmq_publisher_base.py | 3 +- .../client/publishers/zmq_req_publisher.py | 130 ---------------- .../_drivers/zmq_driver/client/zmq_client.py | 20 ++- .../_drivers/zmq_driver/client/zmq_client_base.py | 5 +- .../_drivers/zmq_driver/client/zmq_client_light.py | 46 ------ .../_drivers/zmq_driver/client/zmq_request.py | 10 ++ .../_drivers/zmq_driver/matchmaker/base.py | 124 +++++++-------- .../zmq_driver/matchmaker/matchmaker_redis.py | 18 +++ .../_drivers/zmq_driver/poller/green_poller.py | 6 +- .../_drivers/zmq_driver/poller/threading_poller.py | 5 +- .../server/consumers/zmq_consumer_base.py | 36 ++--- .../server/consumers/zmq_sub_consumer.py | 158 +++++++++++++++++++ .../_drivers/zmq_driver/server/zmq_server.py | 19 ++- oslo_messaging/_drivers/zmq_driver/zmq_address.py | 13 ++ oslo_messaging/_drivers/zmq_driver/zmq_async.py | 9 +- oslo_messaging/_drivers/zmq_driver/zmq_poller.py | 29 ++++ oslo_messaging/_executors/impl_pooledexecutor.py | 7 +- oslo_messaging/_utils.py | 51 ------- oslo_messaging/dispatcher.py | 111 ++++++++++++++ oslo_messaging/notify/__init__.py | 1 + oslo_messaging/notify/dispatcher.py | 168 ++++++++++++++------- oslo_messaging/notify/listener.py | 43 +++++- oslo_messaging/notify/notifier.py | 4 +- oslo_messaging/rpc/dispatcher.py | 13 +- oslo_messaging/serializer.py | 2 - oslo_messaging/server.py | 24 --- .../drivers/zmq/matchmaker/test_impl_matchmaker.py | 13 -- requirements.txt | 4 +- tools/simulator.py | 111 ++++++++++---- tox.ini | 1 + 58 files changed, 1342 insertions(+), 749 deletions(-) Requirements updates -------------------- diff --git a/requirements.txt b/requirements.txt index 2d23543..ba8876a 100644 --- a/requirements.txt +++ b/requirements.txt @@ -11 +11 @@ oslo.log>=1.12.0 # Apache-2.0 -oslo.utils>=2.8.0 # Apache-2.0 +oslo.utils>=3.2.0 # Apache-2.0 @@ -13 +13 @@ oslo.serialization>=1.10.0 # Apache-2.0 -oslo.service>=0.12.0 # Apache-2.0 +oslo.service>=1.0.0 # Apache-2.0