c881baed29

When the application set batch_size, so we don't need to prefetch more messages, especially for notifications. Notifications queues can be really big when the consumer have disapear during a long period, and when it come back, kombu/pyamqp will fetch all messages it can. So we override the qos prefetch value. Change-Id: I601e10cf94310b9f96f7acb9942959aaafad7994 Closes-bug: #1551667
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
Description
Languages
Python
99.8%
Shell
0.2%