CC-2750: Ability to query health status for pypo, liquidsoap,
media monitor, and recorder -cleanup
This commit is contained in:
parent
9fc2932be6
commit
1555c83668
|
@ -90,8 +90,6 @@ class PypoFetch(Thread):
|
||||||
elif command == 'cancel_current_show':
|
elif command == 'cancel_current_show':
|
||||||
logger.info("Cancel current show command received...")
|
logger.info("Cancel current show command received...")
|
||||||
self.stop_current_show()
|
self.stop_current_show()
|
||||||
elif command == 'get_status':
|
|
||||||
self.get_status()
|
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
logger.error("Exception in handling RabbitMQ message: %s", e)
|
logger.error("Exception in handling RabbitMQ message: %s", e)
|
||||||
finally:
|
finally:
|
||||||
|
@ -99,11 +97,7 @@ class PypoFetch(Thread):
|
||||||
try:
|
try:
|
||||||
message.ack()
|
message.ack()
|
||||||
except MessageStateError, m:
|
except MessageStateError, m:
|
||||||
logger.error("Message ACK error: %s", m);
|
logger.error("Message ACK error: %s", m)
|
||||||
|
|
||||||
def get_status(self):
|
|
||||||
logger = logging.getLogger('fetch')
|
|
||||||
logger.debug("get_status")
|
|
||||||
|
|
||||||
def stop_current_show(self):
|
def stop_current_show(self):
|
||||||
logger = logging.getLogger('fetch')
|
logger = logging.getLogger('fetch')
|
||||||
|
|
Loading…
Reference in New Issue