openstack/deb-python-kafka
Code Issues Proposed changes

Fix _mp_consume queue variable name conflict

Browse Source
This commit is contained in:
Dana Powers
2015-12-09 13:56:49 -08:00
parent 035b936d7c
commit 1856063f4e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/consumer/multiprocess.py
View File

@@ -25,7 +25,7 @@ log = logging.getLogger(__name__)
Events = namedtuple("Events", ["start", "pause", "exit"]) Events = namedtuple("Events", ["start", "pause", "exit"])
def _mp_consume(client, group, topic, queue, size, events, **consumer_options): def _mp_consume(client, group, topic, message_queue, size, events, **consumer_options):
""" """
A child process worker which consumes messages based on the A child process worker which consumes messages based on the
notifications given by the controller process notifications given by the controller process
@@ -69,7 +69,7 @@ def _mp_consume(client, group, topic, queue, size, events, **consumer_options):
if message: if message:
while True: while True:
try: try:
queue.put(message, timeout=FULL_QUEUE_WAIT_TIME_SECONDS) message_queue.put(message, timeout=FULL_QUEUE_WAIT_TIME_SECONDS)
break break
except queue.Full: except queue.Full:
if events.exit.is_set(): break if events.exit.is_set(): break