code: protected void subscriptionResponseReceived(IoSession session,
  			SubscriptionMessage subscriptionMessage) {
  		log.info("Received {}", subscriptionMessage);
  		this.receivedSubscription = subscriptionMessage;
  
  		if (this.sentSubscription == null) {
  			log.error(
  					"Protocol error: Received a subscription response without sending a request.\n{}",
  					subscriptionMessage);
  			this._disconnect();
  			return;
  		}
  
  		if (!this.sentSubscription.equals(this.receivedSubscription)) {
  			log.info(
  					"Server did not fully accept subscription request.\nOriginal:\n{}\nAmended\n{}",
  					this.sentSubscription, this.receivedSubscription);
  		}
  
  		for (ConnectionListener listener : this.connectionListeners) {
  			listener.subscriptionReceived(this, subscriptionMessage);
  		}
  	}
docs: Called when a subscription response is received from the aggregator.
  
  @param session
  the session on which message was received.
  @param subscriptionMessage
  the received message.