code: public void processReceivedMessage( Message message, Session session ) throws IOException {
  		this.logger.fine( "The DM's HTTP client is about to process a message (" + message + ") received through a web socket." );
  
  		// HttpMessage
  		if( message instanceof HttpMessage ) {
  			HttpMessage httpMsg = (HttpMessage) message;
  
  			// Store the session
  			registerSession( httpMsg.getOwnerId(), session );
  
  			// Publish the message
  			publish( httpMsg.getCtx(), httpMsg.getMessage());
  		}
  
  		// Subscription message
  		else if( message instanceof SubscriptionMessage ) {
  			SubscriptionMessage sub = (SubscriptionMessage) message;
  
  			// Store the session
  			registerSession( sub.getOwnerId(), session );
  
  			// Update the subscriptions
  			if( sub.isSubscribe())
  				subscribe( sub.getOwnerId(), sub.getCtx());
  			else
  				unsubscribe( sub.getOwnerId(), sub.getCtx());
  		}
  	}
docs: Processes a message received from a web socket (i.e. sent by agents).
  @param message a message
  @throws IOException