@Override
	public void onAdd(Response response) {
		String message = gson.toJson(response);
		
		try {
			RabbitMqUtils.sendMessage(message, buildQueueNames(response), environment);
		} catch (IOException e) {
			logger.error("Failed to send response message to output queue.", e);
		}
	}
@ Override public void onAdd ( Response response ) { String message = gson . toJson ( response ) ; try { RabbitMqUtils . sendMessage ( message , buildQueueNames ( response ) , environment ) ; } catch ( IOException e ) { logger . error ( "Failed to send response message to output queue." , e ) ; } }
This implementation of onAdd watches for responses, and immediately sends them out to the
appropriate exchange/queue for routing to the necessary client application(s)