Ускорение интеграции исходящих каналов и постоянная базы данных интеграции

Question

Я работаю над приложением, которое публикует сообщение в очереди с использованием адаптера исходящего канала. Существует новое требование, чтобы уникальный идентификатор, созданный во время обработки сообщения, сохранялся в базе данных после успешного опубликования в очереди, не дожидаясь ответа.

Может кто-нибудь, пожалуйста, сообщите, какой должен быть лучший подход для этого.

Это то, что у меня есть в моем существующем приложении.

<int:gateway id="writerGateway" service-interface="CustomService" default-request-channel="writerChannel"> 
</int:gateway> 

<int-jms:outbound-channel-adapter channel="writerChannel" jms-template="jmsTemplate" destination-name="${queueName}" extract-payload="true"/> 

<int:channel id="writerChannel"> 
    <int:interceptors> 
     <int:wire-tap channel="writerLogger"/> 
    </int:interceptors> 
</int:channel> 

<int:logging-channel-adapter id="writerLogger" logger-name="writerLogger" level="INFO" expression="'Sending ' + payload?.size() + ' events'"/> 

Любая помощь будет очень признательна.

Спасибо, AK

Answer 1

Сделать writerChannel в <publish-subscribe-channel/> и подписаться второй поток (order="2") к нему, например, transformer -> jdbc-outbound-channel-adapter. Установите order="1" на адаптер jms, и второй поток будет вызван, если передача jms завершится успешно.

В качестве альтернативы используйте <recipient-list-router/>.