@staticmethod
def _unsubscribe(sub_id):
    """Stop listening to a queue or a broadcast
        :param sub_id: ID for this subscription in the transport layer
        """
    raise NotImplementedError('Transport interface not implemented')
