Adam Harwell 8a7e13b95b Producer/endpoint code to allow for amphora failovers ... Change-Id: I06b0ec785610c2113384e1da638a56e93b1ab38d		2017-12-21 12:02:20 -08:00
..
__init__.py	Implemented Queue Consumer	2015-04-30 16:48:09 -05:00
consumer.py	Use 'get_rpc_transport' for RPC clients and servers.	2017-06-21 16:54:52 -04:00
endpoint.py	Producer/endpoint code to allow for amphora failovers	2017-12-21 12:02:20 -08:00
event_queue.py	Make the event streamer transport URL configurable	2017-10-25 10:52:48 -07:00