Блог

Я зарегистрировал, AsyncHandler а также добавил success-channel в исходящий поток SQS. У success-channel есть int:logging-channel-adapter конечная точка. Однако я не могу видеть никаких журналов с этого адаптера. AsyncHandler Может принимать обратные вызовы, но ничего на success-channel . В SqsMessageHandler я вижу, что мы устанавливаем выходной канал в obtainAsyncHandler методе, но я нигде не видел success-channel установленного. Я что-то упускаю? Я бы предпочел использовать каналы success и failure, а не обратный вызов AsyncHandler Impl, чтобы избежать использования специфичного для AWS кода в моих классах.

Также мой <int-aws:sqs-outbound-channel-adapter> находится внутри <int:chain> , у которого нет выходного канала, поскольку поток заканчивается при отправке сообщения.

РЕДАКТИРОВАТЬ — Добавлена конфигурация Это единственный способ, которым я могу заставить его регистрировать обратный вызов.

     <int:channel id="chainChannel" />
    <int:channel id="successChannel" />
    <bean class="ServiceTransformer" id="serviceTransformer" />
    <int:chain input-channel="serviceChannel" id="sendToServiceSqsChain" output-channel="chainChannel">
        <int:transformer ref="serviceTransformer" method="transform" />
        <int:header-filter header-names="config" />
        <int-aws:sqs-outbound-channel-adapter sqs="amazonSQS" queue="some-queue" async-handler="sqsPublishCallbackHandler" success-channel="successChannel"/>
    </int:chain>

    <int:logging-channel-adapter log-full-message="true" channel="chainChannel" />
  

Здесь я могу просто использовать один и тот же канал как в цепочке (исходящий канал), так и в sqs-outbound (success-channel)

Не удается заставить его работать, как показано ниже:

         <int:channel id="successChannel" />
        <bean class="ServiceTransformer" id="serviceTransformer" />
        <int:chain input-channel="serviceChannel" id="sendToServiceSqsChain" >
            <int:transformer ref="serviceTransformer" method="transform" />
            <int:header-filter header-names="config" />
            <int-aws:sqs-outbound-channel-adapter sqs="amazonSQS" queue="some-queue" async-handler="sqsPublishCallbackHandler" success-channel="successChannel"/>
        </int:chain>
    
        <int:logging-channel-adapter log-full-message="true" channel="successChannel" />
  

<int-aws:sqs-outbound-channel-adapter> Компонент является односторонним, поэтому нет outputChannel опции expose. Однако целевой класс является AbstractMessageProducingHandler . Чтобы избежать дублирования кода, мы повторно используем существующий outputChannel внутренний для этого AsyncHandler .

В анализаторе XML мы просто переназначаем одно на другое:

 IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "success-channel", "outputChannel");
  

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

Обновить

Согласно моему тестированию, определенно невозможно настроить такой компонент с XML DSL в <chain> . Это <int-aws:sqs-outbound-channel-adapter> должно быть представлено за пределами <chain> .

Рассмотрите возможность дополнительной настройки на Java DSL вместо этого: https://docs.spring.io/spring-integration/docs/5.3.2.RELEASE/reference/html/dsl.html#java-dsl .