"Missing closesubscription request data");
closesubStats.incrementFailedOps();
return;
}
final CloseSubscriptionRequest closesubRequest =
request.getCloseSubscriptionRequest();
final ByteString topic = request.getTopic();
final ByteString subscriberId = closesubRequest.getSubscriberId();
final long requestTime = System.currentTimeMillis();
subMgr.closeSubscription(topic, subscriberId, new Callback<Void>() {
@Override