summaryrefslogtreecommitdiff
path: root/oslo/messaging/_drivers/impl_zmq.py
diff options
context:
space:
mode:
authorGordon Sim <gsim@redhat.com>2014-02-21 21:13:17 +0000
committerKenneth Giusti <kgiusti@gmail.com>2014-09-04 15:12:43 -0400
commitfbee94170f918c165ac4e7eb3bacd0dc193acc50 (patch)
treeba2b123b67586a99969a9910db8927cfdb3cd941 /oslo/messaging/_drivers/impl_zmq.py
parenta9ec73f38db804858c10267ca5da721232c4dd70 (diff)
An initial implementation of an AMQP 1.0 based messaging driver
The key driver interfaces are implemented in the ProtonDriver class in driver.py. The logic for interfacing with Pyngus in order to send/receive messages, manage AMQP connections and links, and handle protocol events is in controller.py. eventloop.py is a fairly generic socket connection and I/O processor which runs in its own thread. controller.py uses the eventloop.py thread to schedule subscription and message send requests from the driver, as well as handle all protocol event callbacks coming from Pyngus. Included in this patch are a set of functional tests that can be run under tox (tox -eamqp1). These tests fully exercise the new driver, from the driver API down to the 'wire' - nothing in the driver is mocked out. The functional tests implement a simple loopback test broker, which allows the driver to send and receive messages via the local network. All RPC call patterns, RPC timeouts, and even broker failover are verified by the included functional tests. This driver uses the Pyngus module, which is a pure-python client API built on the Proton AMQP 1.0 protocol engine library from the Apache Qpid project. Pyngus is available via pypi.python.org. This driver introduces a dependency on the Proton AMQP 1.0 protocol library, which is a platform-dependent library that must be installed in order to use this driver and run the functional tests. Change-Id: I871703e4cdc04cee3e6c214e911c9df464ede2ed Implements: blueprint amqp10-driver-implementation
Notes
Notes (review): Verified+2: Jenkins Code-Review+2: Doug Hellmann <doug@doughellmann.com> Workflow+1: Doug Hellmann <doug@doughellmann.com> Code-Review+2: Mehdi Abaakouk <mehdi.abaakouk@enovance.com> Code-Review+2: Flavio Percoco <fpercoco@redhat.com> Code-Review+1: Ilya Pekelny <ipekelny@mirantis.com> Code-Review+1: Gordon Sim <gsim@redhat.com> Submitted-by: Jenkins Submitted-at: Sat, 06 Sep 2014 08:56:41 +0000 Reviewed-on: https://review.openstack.org/75815 Project: openstack/oslo.messaging Branch: refs/heads/master
Diffstat (limited to 'oslo/messaging/_drivers/impl_zmq.py')
0 files changed, 0 insertions, 0 deletions