code: @Override
  	public void onAdd(Response response) {
  		String message = gson.toJson(response);
  		
  		try {
  			ActiveMqUtils.sendMessage(message, buildQueueNames(response), environment);
  		} catch (JMSException e) {
  			logger.error("Failed to send response message to output queue.", e);
  		}
  	}
docs: 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)