We are high-spirited to announce the release of: oslo.messaging 5.11.0: Oslo Messaging API
This release is part of the ocata release series. The source is available from: http://git.openstack.org/cgit/openstack/oslo.messaging Download the package from: 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 5.10.0..5.11.0 ---------------------------------------- 4ba1b59 Fix typos in addressing.py and setup.cfg 96b9618 Updated from global requirements 86e779b Record length of queues for ReplyWaiters c881bae rabbit: Don't prefetch when batch_size is set bc46e64 [AMQP 1.0] Avoid unnecessary thread switch on ack c0e941f [zmq] Fix issues with broken messages on proxies cb3af21 [zmq] Maintain several redis hosts fa43769 Removed redundant 'the' ea001a8 Fix a typo in server.py beb2310 [document] The example which is written in the developer guide of 'Notification Listener' doesn't work. 7a1694b Enable release notes translation 03ef584 cast() and RPC replies should not block waiting for endpoint to ack dd8e9fb [simulator] Automatic stopping of rpc-servers 4c67917 Fix whitespace formatting issue da83001 Properly deserializes built-in exceptions 86f4b80 [zmq] Fix send_cast in AckManager 9775ed3 Remove debug logs from fast path a5e2a63 [zmq] Routing table refactoring, dynamic direct connections e491573 Fix simulator bool command line args d1fe205 Replace 'the' with 'to' in docstring 4b1ac84 Remove default=None when set value in Config 22c93b2 [zmq] Add acks from proxy for PUB/SUB messages 2b47281 [zmq] Refactor consumers and incoming messages 27594bd [zmq] Make second ROUTER socket optional for proxy ae365cb Use method fetch_current_thread_functor from oslo.utils fc093c3 [zmq] Fix ZmqSocket.send_string f3ea04c [zmq] Remove unused methods from executors 64c5e50 [zmq] Added a processing to handle ImportError in Redis plugin of Matchmaker 4e38293 modify the home-page info with the developer documentation e9e1645 Set the valid choices for the rabbit login methods b3cb65a [zmq] Unify delimeters c3df59e [zmq] Fix fanout without PUB/SUB a9814d4 [zmq] Send immediate ack after message receiving afaa4d9 Corrects documentation typo eaf433b [zmq] Remove unnecessary subscriptions from SubConsumer 9bc9c0d Fixups to the inline documentation 3f4ce94 Fix consuming from unbound reply queue 9bd4bbe Add configurable serialization to pika 16ce974 [zmq] Remove ZmqSocket.close_linger attribute b5c82e9 [zmq] Make ZMQ TCP keepalive options configurable 09816f0 [zmq] Fix TestZmqAckManager periodic failure 3aa5982 [zmq] Make ThreadingPoller work with ZmqSocket 3cdfe15 Fix notify filter when data item is None c2e5645 [zmq] Rename rpc_cast_timeout option c5d142b [AMQP 1.0] Update setup test environment dispatch router backend d3a8f28 Allow dispatcher to restrict endpoint methods. e451a9e [AMQP 1.0] Add Acknowledgement and Batch Notification Topics e4f22c9 Update reno for stable/newton 204dfa7 [kafka] invoke TypeError exception when 'listen()' method of KafkaDriver is called 6866948 [zmq] Proxy has to skip broken multi-part message 799bd0e Add Documentation String for PikaDriver fab75e7 [zmq] Implement retries for unacknowledged CALLs 6c973da [AMQP 1.0] Make the default settlement behavior configurable 777f520 [zmq] Eliminate GreenPool from GreenPoller 88003cb Avoid sending cast after server shutdown in functional test 6881d14 [zmq] Update ZMQ-driver documentation e5785f6 [zmq] Add --log-file option to zmq-proxy Diffstat (except docs and test files) ------------------------------------- oslo_messaging/_cmd/zmq_proxy.py | 73 +---- oslo_messaging/_drivers/amqp1_driver/addressing.py | 2 +- oslo_messaging/_drivers/amqp1_driver/controller.py | 108 +++---- oslo_messaging/_drivers/amqp1_driver/opts.py | 18 +- oslo_messaging/_drivers/amqpdriver.py | 19 +- oslo_messaging/_drivers/common.py | 8 + oslo_messaging/_drivers/impl_amqp1.py | 40 +-- oslo_messaging/_drivers/impl_kafka.py | 2 +- oslo_messaging/_drivers/impl_pika.py | 17 + oslo_messaging/_drivers/impl_rabbit.py | 78 ++--- oslo_messaging/_drivers/impl_zmq.py | 13 +- .../_drivers/pika_driver/pika_commons.py | 7 + oslo_messaging/_drivers/pika_driver/pika_engine.py | 4 + .../_drivers/pika_driver/pika_message.py | 49 ++- .../publishers/dealer/zmq_dealer_publisher_base.py | 64 +--- .../dealer/zmq_dealer_publisher_direct.py | 63 +++- .../dealer/zmq_dealer_publisher_proxy.py | 98 ++++-- .../client/publishers/zmq_publisher_base.py | 59 ++-- .../_drivers/zmq_driver/client/zmq_ack_manager.py | 93 +++--- .../_drivers/zmq_driver/client/zmq_client.py | 42 +-- .../_drivers/zmq_driver/client/zmq_client_base.py | 36 ++- .../zmq_driver/client/zmq_publisher_manager.py | 148 +++++++++ .../_drivers/zmq_driver/client/zmq_receivers.py | 7 +- .../_drivers/zmq_driver/client/zmq_request.py | 2 +- .../zmq_driver/client/zmq_routing_table.py | 221 +++++++++---- .../_drivers/zmq_driver/client/zmq_senders.py | 72 +++-- .../zmq_driver/client/zmq_sockets_manager.py | 59 +--- .../zmq_driver/matchmaker/zmq_matchmaker_base.py | 69 ++++- .../zmq_driver/matchmaker/zmq_matchmaker_redis.py | 345 ++++++++++++++------- .../_drivers/zmq_driver/poller/green_poller.py | 27 +- .../_drivers/zmq_driver/poller/threading_poller.py | 45 ++- .../_drivers/zmq_driver/proxy/central/__init__.py | 0 .../zmq_driver/proxy/central/zmq_central_proxy.py | 181 +++++++++++ .../proxy/central/zmq_publisher_proxy.py | 60 ++++ .../_drivers/zmq_driver/proxy/zmq_proxy.py | 104 ++++++- .../zmq_driver/proxy/zmq_publisher_proxy.py | 74 ----- .../_drivers/zmq_driver/proxy/zmq_queue_proxy.py | 154 --------- .../_drivers/zmq_driver/proxy/zmq_sender.py | 93 ++++++ .../server/consumers/zmq_consumer_base.py | 14 +- .../server/consumers/zmq_dealer_consumer.py | 158 ++++++---- .../server/consumers/zmq_router_consumer.py | 73 +++-- .../server/consumers/zmq_sub_consumer.py | 42 +-- .../zmq_driver/server/zmq_incoming_message.py | 50 +-- .../_drivers/zmq_driver/server/zmq_server.py | 37 ++- .../_drivers/zmq_driver/server/zmq_ttl_cache.py | 46 ++- oslo_messaging/_drivers/zmq_driver/zmq_address.py | 30 +- oslo_messaging/_drivers/zmq_driver/zmq_names.py | 23 +- oslo_messaging/_drivers/zmq_driver/zmq_options.py | 53 +++- oslo_messaging/_drivers/zmq_driver/zmq_poller.py | 12 +- oslo_messaging/_drivers/zmq_driver/zmq_socket.py | 95 ++++-- oslo_messaging/_drivers/zmq_driver/zmq_updater.py | 8 +- oslo_messaging/_utils.py | 21 -- oslo_messaging/notify/filter.py | 26 +- oslo_messaging/notify/listener.py | 116 ++++--- oslo_messaging/notify/messaging.py | 21 ++ oslo_messaging/notify/notifier.py | 27 +- oslo_messaging/opts.py | 4 +- oslo_messaging/rpc/__init__.py | 5 + oslo_messaging/rpc/client.py | 111 ++++--- oslo_messaging/rpc/dispatcher.py | 85 ++++- oslo_messaging/rpc/server.py | 95 ++++-- oslo_messaging/target.py | 32 +- .../drivers/zmq/matchmaker/test_impl_matchmaker.py | 38 ++- releasenotes/source/conf.py | 3 + releasenotes/source/index.rst | 1 + releasenotes/source/newton.rst | 6 + requirements.txt | 8 +- setup-test-env-amqp1.sh | 191 ++++++++++++ setup-test-env-qpid.sh | 115 ------- setup.cfg | 5 +- test-requirements.txt | 6 +- tools/simulator.py | 147 +++++++-- tox.ini | 24 +- 92 files changed, 3360 insertions(+), 1755 deletions(-) Requirements updates -------------------- diff --git a/requirements.txt b/requirements.txt index 3be9ded..59af9c1 100644 --- a/requirements.txt +++ b/requirements.txt @@ -10 +10 @@ oslo.context>=2.9.0 # Apache-2.0 -oslo.log>=1.14.0 # Apache-2.0 +oslo.log>=3.11.0 # Apache-2.0 @@ -15 +15 @@ oslo.i18n>=2.1.0 # Apache-2.0 -stevedore>=1.16.0 # Apache-2.0 +stevedore>=1.17.1 # Apache-2.0 @@ -30 +30 @@ greenlet>=0.3.2 # MIT -WebOb>=1.2.3 # MIT +WebOb>=1.6.0 # MIT @@ -33 +33 @@ WebOb>=1.2.3 # MIT -PyYAML>=3.1.0 # MIT +PyYAML>=3.10.0 # MIT diff --git a/test-requirements.txt b/test-requirements.txt index 1e3f508..b5a1384 100644 --- a/test-requirements.txt +++ b/test-requirements.txt @@ -32,2 +32,2 @@ coverage>=3.6 # Apache-2.0 -sphinx!=1.3b1,<1.3,>=1.2.1 # BSD -oslosphinx!=3.4.0,>=2.5.0 # Apache-2.0 +sphinx!=1.3b1,<1.4,>=1.2.1 # BSD +oslosphinx>=4.7.0 # Apache-2.0 @@ -38 +38 @@ reno>=1.8.0 # Apache2 -pyngus>=2.0.0 # Apache-2.0 +pyngus>=2.0.2 # Apache-2.0 __________________________________________________________________________ OpenStack Development Mailing List (not for usage questions) Unsubscribe: openstack-dev-requ...@lists.openstack.org?subject:unsubscribe http://lists.openstack.org/cgi-bin/mailman/listinfo/openstack-dev