more comment reformatting
This commit is contained in:
@@ -115,10 +115,10 @@ class AdapterConsumer(TopicConsumer):
|
|||||||
args = message_data.get('args', {})
|
args = message_data.get('args', {})
|
||||||
message.ack()
|
message.ack()
|
||||||
if not method:
|
if not method:
|
||||||
# vish: we may not want to ack here, but that means that bad
|
# NOTE(vish): we may not want to ack here, but that means that bad
|
||||||
# messages stay in the queue indefinitely, so for now
|
# messages stay in the queue indefinitely, so for now
|
||||||
# we just log the message and send an error string back
|
# we just log the message and send an error string
|
||||||
# to the caller
|
# back to the caller
|
||||||
_log.warn('no method for message: %s' % (message_data))
|
_log.warn('no method for message: %s' % (message_data))
|
||||||
msg_reply(msg_id, 'No method for message: %s' % message_data)
|
msg_reply(msg_id, 'No method for message: %s' % message_data)
|
||||||
return
|
return
|
||||||
|
|||||||
Reference in New Issue
Block a user