if DmaapLibrary.server_thread is not None:
DmaapLibrary.dmaap_queue.clean_up_event()
logger.console("DMaaP event queue is cleaned up")
if DmaapLibrary.server_thread is not None:
DmaapLibrary.dmaap_queue.clean_up_event()
logger.console("DMaaP event queue is cleaned up")