RabbitEventSender.java 文件源码

@Override
@Async
public Future<Void> send(EventEndpoint endpoint, final ApplicationEventNFVO event) {

  log.debug("Sending message: " + event + " to endpoint: " + endpoint);
  log.info("Sending message: " + event.getAction() + " to endpoint: " + endpoint.getName());
  final String json =
      "{\"action\":\""
          + event.getAction()
          + "\",\"payload\":"
          + new Gson().toJson(event.getPayload())
          + "}";
  log.trace("Event body is: " + json);
  rabbitTemplate.convertAndSend(endpoint.getEndpoint(), json);

  return new AsyncResult<>(null);
}