3

编辑：这是显示我的日志的要点。似乎有 ReceiveMessage，然后是preSendon inputChannel：

https://gist.github.com/louisalexander/04e7d95835521efdd15455c98075e2ea

抱歉如此密集，但我似乎无法弄清楚如何正确利用sqs-message-driven-channel-adapter

在我的上下文文件中，我将其配置为：

<int-aws:sqs-message-driven-channel-adapter
    id="my-message-driven-adapter" sqs="sqs" queues="some-queue-of-mine"
    max-number-of-messages="5" visibility-timeout="200" wait-time-out="10"
    send-timeout="2000" channel="inputChannel" />

我观察到消息正确地进入some-queue-of-mine（通过删除上面的代码位并将消息发送到队列）。然后我重新启动我的服务器，启用消息驱动适配器，我观察到所有消息都从队列中消耗，但是它们去哪里了？：-/

我的期望是这些消息将被汇集到一个DirectChannel命名中inputChannel：

<int:channel id="inputChannel"/>

我有一个service-activator消费如下：

<int:service-activator ref="myConsumer"
    method='execute' input-channel="inputChannel" output-channel="outputChannel">
    <int:request-handler-advice-chain>
        ...
    </int:request-handler-advice-chain>
</int:service-activator>

但是，当然，我从来没有看到myConsumer被调用。我想我对MessageProducer机制如何工作的理解是不够的。有人可以通过提供 XML 连接的简单示例来纠正我的想法吗？

4

1 回答 1

1

根据日志，消息由handler.AbstractMessageHandler (AbstractMessageHandler.java:115) - ServiceActivator for [org.springframework.integration.handler.MethodInvokingMessageProcessor@493f49cd]. 尽管这可能是一个完全不同的故事。

SqsMessageDrivenChannelAdapter可以提供errorChannel以处理下游异常。默认情况下，它只被记录。

从该适配器发送的消息如下：

return new GenericMessage<>(message.getBody(), new SqsMessageHeaders(messageHeaders));

message.getBody()那是哪里String。见QueueMessageUtils.createMessage()。

因此，请确保您service-activator接受它String作为paylaod，而不是任何其他类型。

于 2017-02-15T20:20:45.623 回答