обратный вызов, когда сообщение написано в RabbitMQ - PullRequest
Новая
       26

обратный вызов, когда сообщение написано в RabbitMQ

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

Я хочу обновить таблицу базы данных, когда сообщение успешно вставлено в RabbitMQ.

Мое приложение основано на Spring и использует: 

import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlowBuilder;
import org.springframework.integration.dsl.IntegrationFlows;

Я нашел wireTap () иЯ использую его так: 

flowBuilder.wireTap(sf -> 
    sf.handle( m -> {
                     logger.info("WireTap:  m.getPayload()="+m.getPayload().toString());
                    }
    )
);

Однако тестирование показывает, что оно регистрирует сообщение, даже если RabbitMQ не запущен ... так что оно близко к тому, что я хочу, но не совсем.

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

Меня не волнует передача или получение, я просто хочузнать, если сообщение сделало это.

...