+ topicSubscriber);
}
// tell subscribe response handler to stop delivering messages for a given topic subscriber
topicSubscriber2MessageHandler.remove(topicSubscriber);
subscribeResponseHandler.stopDelivery(topicSubscriber);
}
@Override
public void asyncCloseSubscription(final TopicSubscriber topicSubscriber,