Andrew Smith 1ccdccddaa Add kafka driver vhost emulation ... Emulate vhost support by adding the virtual host name to the topic created on the kafka server. Also, update connection management for producer/consumer. This patch: * updates target to topic generation * add consumer and producer connection classes * remove connection pool * update driver test Change-Id: Idd164444c04e9f465a43ee909af840a41bb090c0		2017-12-27 12:57:39 -05:00
..
_cmd	[zmq] Prevent access to rpc_response_timeout	2017-03-23 13:47:33 -04:00
_drivers	Add kafka driver vhost emulation	2017-12-27 12:57:39 -05:00
hacking	Test:Use unittest.mock on Python 3	2017-02-08 19:15:17 +08:00
notify	Merge "sort when using groupby"	2017-11-29 19:43:46 +00:00
rpc	Fix default value of RPC dispatcher access_policy	2017-09-24 20:25:38 -07:00
tests	Add kafka driver vhost emulation	2017-12-27 12:57:39 -05:00
__init__.py	Remove deprecated localcontext	2016-05-18 09:28:15 +02:00
_i18n.py	Update URLs in documents according to document migration	2017-07-12 22:54:02 +08:00
_utils.py	Use method fetch_current_thread_functor from oslo.utils	2016-09-24 15:22:44 +08:00
conffixture.py	Remove usage of parameter enforce_type	2017-04-11 14:32:53 +08:00
dispatcher.py	Remove useless logging import statements	2016-11-08 10:11:13 +08:00
exceptions.py	Move files out of the namespace package	2015-01-12 12:50:41 -05:00
opts.py	Add kafka_driver directory	2017-06-13 08:46:50 -04:00
serializer.py	serializer: remove deprecated RequestContextSerializer	2017-03-29 16:21:17 +08:00
server.py	rabbitmq: don't wait for message ack/requeue	2017-11-29 21:13:50 +01:00
target.py	Fixups to the inline documentation	2016-09-12 09:49:00 -04:00
transport.py	Flesh out transport_url help	2017-10-06 20:04:34 +00:00
version.py	pbr.version.VersionInfo needs package name (oslo.xyz and not oslo_xyz)	2017-02-06 12:49:23 -05:00