f2f2d07c28
This patch fixes the problem of sending fanout messages to listeners located on the same host via the pika transport driver. Only one listener per host received a fanout message before, because actually there was only one queue per host, and that queue simply dispatched incoming messages to listeners in a round robbin manner. In order to fix this behaviour, every listener is supplied by its own unique message queue bound to an appropriate fanout exchange now. Since internal states of pika listeners (or pollers) were changed, some tests related to pika pollers were also updated properly. In addition, terms related to sending fanout messages to all_servers listening some topic are refered to all_workers now (for better description of what is really going on). Closes-Bug: #1551661 Change-Id: I5aab6bee8758658fa3fa7e329b54ffa438e85f61
Oslo Messaging Library
The Oslo messaging API supports RPC and notifications over a number of different messaging transports.
- License: Apache License, Version 2.0
- Documentation: http://docs.openstack.org/developer/oslo.messaging
- Source: http://git.openstack.org/cgit/openstack/oslo.messaging
- Bugs: http://bugs.launchpad.net/oslo.messaging