Consumer start log appears at appropriate time
Change-Id: I5034fd56140f0a9ce65edc1d0d9c860a6ad4da98
This commit is contained in:
parent
3906b9f394
commit
e2453a0cc8
@ -37,8 +37,8 @@ class Consumer(object):
|
||||
|
||||
def listen(self):
|
||||
try:
|
||||
LOG.info(_LI('Starting consumer...'))
|
||||
service.launch(cfg.CONF, self.server).wait()
|
||||
LOG.info(_LI('Consumer is now listening...'))
|
||||
finally:
|
||||
LOG.info(_LI('Stopping consumer...'))
|
||||
self.server.stop()
|
||||
|
Loading…
x
Reference in New Issue
Block a user