def stop_consuming_signalling_topic(signalling_topic_data):
    signalling_topic_data = json.loads(signalling_topic_data)
    logger.info('Stopping %s topic', signalling_topic_data['topic'])
    logger.info('Sending DELETE request to %s', url_unsubscribe)
    r = requests.delete(url_unsubscribe, json=signalling_topic_data)
    logger.info('Response: Code %s', r)
    global signalling_start
    signalling_start = False
def stop_consuming_signalling_topic(signalling_topic_data):
    signalling_topic_data = json.loads(signalling_topic_data)
    logger.info('Stopping %s topic', signalling_topic_data['topic'])
    logger.info('Sending DELETE request to %s', url_unsubscribe)
    r = requests.delete(url_unsubscribe, json=signalling_topic_data)
    logger.info('Response: Code %s', r)
    global signalling_start
    signalling_start = False