We are pleased to announce the release of: oslo.messaging 3.1.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 the git log history below and: http://launchpad.net/oslo.messaging/+milestone/3.1.0 Please report issues through launchpad: http://bugs.launchpad.net/oslo.messaging Changes in oslo.messaging 3.0.0..3.1.0 -------------------------------------- 8c03a6d default of kombu_missing_consumer_retry_timeout 18d1708 rename kombu_reconnect_timeout option 822b803 Skip Cyrus SASL tests if proton does not support Cyrus SASL 74a0ec8 setUp/tearDown decorator for set/clear override b6ad95e Support older notifications set_override keys daddb82 Don't hold the connection when reply fail cc97ba2 doc: explain rpc call/cast expection 67c6303 Add a driver for Apache Kafka 33c1010 Option group for notifications 357dcb7 Move ConnectionPool and ConnectionContext outside amqp.py 6ae4679 Use round robin failover strategy for Kombu driver 6cd1dce Revert "serializer: remove deprecated RequestContextSerializer" 067cac3 Updated from global requirements 47baebd [zmq] Random failure with ZmqPortRangeExceededException eea60cf [zmq] Driver optimizations for CALL a811cf3 Updated from global requirements 533a0f8 Use oslo_config new type PortOpt for port options fb2037b serializer: remove deprecated RequestContextSerializer a33c761 Add log info for AMQP client 4ea583b Updated from global requirements 6dba2ed Add Warning when we cannot notify 16f956d ignore .eggs directory 196980d serializer: deprecate RequestContextSerializer 47a906a middleware: remove oslo.context usage 925eb73 Remove qpidd's driver from the tree Diffstat (except docs and test files) ------------------------------------- .gitignore | 1 + oslo_messaging/_drivers/amqp.py | 119 +-- oslo_messaging/_drivers/amqpdriver.py | 83 +- oslo_messaging/_drivers/common.py | 96 +++ oslo_messaging/_drivers/impl_kafka.py | 363 +++++++++ oslo_messaging/_drivers/impl_qpid.py | 800 ------------------- oslo_messaging/_drivers/impl_rabbit.py | 109 ++- oslo_messaging/_drivers/impl_zmq.py | 27 +- oslo_messaging/_drivers/pool.py | 26 + .../_drivers/zmq_driver/broker/zmq_queue_proxy.py | 20 +- .../client/publishers/dealer/__init__.py | 0 .../publishers/dealer/zmq_dealer_call_publisher.py | 194 +++++ .../publishers/dealer/zmq_dealer_publisher.py | 118 +++ .../dealer/zmq_dealer_publisher_proxy.py | 87 +++ .../client/publishers/zmq_dealer_publisher.py | 180 ----- .../client/publishers/zmq_pub_publisher.py | 9 +- .../client/publishers/zmq_publisher_base.py | 36 +- .../client/publishers/zmq_push_publisher.py | 10 +- .../client/publishers/zmq_req_publisher.py | 19 +- .../_drivers/zmq_driver/client/zmq_client.py | 79 +- .../_drivers/zmq_driver/client/zmq_client_base.py | 77 ++ .../_drivers/zmq_driver/client/zmq_client_light.py | 46 ++ .../zmq_driver/matchmaker/matchmaker_redis.py | 6 +- .../_drivers/zmq_driver/poller/threading_poller.py | 3 + .../server/consumers/zmq_consumer_base.py | 10 +- .../server/consumers/zmq_pull_consumer.py | 6 +- .../server/consumers/zmq_router_consumer.py | 14 +- .../zmq_driver/server/zmq_incoming_message.py | 5 +- oslo_messaging/_drivers/zmq_driver/zmq_async.py | 10 + oslo_messaging/_drivers/zmq_driver/zmq_socket.py | 3 + oslo_messaging/conffixture.py | 56 +- oslo_messaging/notify/_impl_log.py | 5 + oslo_messaging/notify/_impl_routing.py | 8 +- oslo_messaging/notify/log_handler.py | 3 +- oslo_messaging/notify/logger.py | 2 +- oslo_messaging/notify/middleware.py | 5 +- oslo_messaging/notify/notifier.py | 43 +- oslo_messaging/opts.py | 3 - oslo_messaging/rpc/client.py | 10 + oslo_messaging/serializer.py | 2 + oslo_messaging/transport.py | 4 +- requirements.txt | 4 +- setup.cfg | 4 +- test-requirements.txt | 6 +- tools/simulator.py | 4 +- tox.ini | 4 - 61 files changed, 1798 insertions(+), 2272 deletions(-) Requirements updates -------------------- diff --git a/requirements.txt b/requirements.txt index 819fc24..2d23543 100644 --- a/requirements.txt +++ b/requirements.txt @@ -15,0 +16 @@ stevedore>=1.5.0 # Apache-2.0 +debtcollector>=0.3.0 # Apache-2.0 @@ -21 +21,0 @@ cachetools>=1.0.0 # MIT License -debtcollector>=0.3.0 # Apache-2.0 @@ -40 +40 @@ kombu>=3.0.7 -oslo.middleware>=2.9.0 # Apache-2.0 +oslo.middleware>=3.0.0 # Apache-2.0 diff --git a/test-requirements.txt b/test-requirements.txt index 0c0f4e8..1387e1a 100644 --- a/test-requirements.txt +++ b/test-requirements.txt @@ -18,3 +17,0 @@ oslotest>=1.10.0 # Apache-2.0 -# for test_qpid -qpid-python;python_version=='2.7' - @@ -26,0 +24,3 @@ pyzmq>=14.3.1 # LGPL+BSD +# for test_impl_kafka +kafka-python>=0.9.2 # Apache-2.0 +