EventConsumer resultConsumer = consumers.get(endpoint.getId());
if (resultConsumer == null) {
resultConsumer = eventTransportFactory.getEventConsumer(Constants.RESULT_PREFIX + Constants.SEPARATOR + clusterManager.getNode().getId() + endpoint.getId(), Boolean.FALSE);
consumers.put(endpoint.getId(), resultConsumer);
} else if (!resultConsumer.isConsuming()) {
resultConsumer.start();
}
producers.put(endpoint.getId(), requestProducer);
consumers.put(endpoint.getId(), resultConsumer);