Apache Camen и RabbitMQ: как я могу получить подтверждение после помещения сообщения на Rabbitmq через Apache Carmel и AWS SQS - PullRequest
Новая
       32

Apache Camen и RabbitMQ: как я могу получить подтверждение после помещения сообщения на Rabbitmq через Apache Carmel и AWS SQS

0 голосов
/ 30 апреля 2019

Я новичок в Apache Camel и Messaging:

У меня есть конечная точка SOAP, которая использует запрос мыла и читает заголовок для информации о маршрутизации.

Затем использует Apache Camel для маршрутизации сообщения.в пункт назначения RabbitMQ следующим образом:

Ниже приведен фрагмент кода. 

    org.apache.camel.ProducerTemplate producerTemplate;

     String json;
        try {
          json = objectMapper.writeValueAsString(soapXML);
        } catch (JsonProcessingException e) {
          throw new SoapException("Unable to map soap message to json ", e.getCause());
        }

        log.info("About to add event to the message broker ..", json);
    //producerTemplate is initialised via service constructor
        producerTemplate.sendBodyAndHeaders(SoapEventRoute.ROUTE_EVENT, json, headers);

  // TODO: Logic to confirm message was successfully routed and placed on queue?

Q1.Как подтвердить и записать, что сообщение было успешно помещено в очередь.

Q2.Приведенный выше код будет заменен на AWS SQS для производства.Как будет выполняться проверка подтверждения успеха с использованием AWS SQS.

Будут оценены любые советы или ссылки.

Также будет приветствоваться любой фрагмент кода / ссылки.

Спасибо.

ПРИМЕЧАНИЕ. Приведенный выше код работает, и сообщение успешно помещено в очередь, но я работаю над обработкой ошибок / исключений и контрольным журналом и т. Д. Для создания кода.

...