Spring Integration：如何读取队列中未消费的消息？

【问题标题】：Spring Integration: How to read the unconsumed messages in the queue?Spring Integration：如何读取队列中未消费的消息？
【发布时间】：2014-07-03 21:48:51
【问题描述】：

我正在尝试读取队列通道中未使用的消息。但是找不到办法。可能吗？如果是，请指出正确的文件。

目的是公开一个 API，以便客户端可以在 UI 上看到待处理的项目。

谢谢，

【问题讨论】：

标签： java spring queue spring-integration message-queue

【解决方案1】：

您可以在其中一个 ServiceActivator 中简单地引用“队列通道”，然后对消息做任何您想做的事情：

@MessageEndpoint(value = "jobQueuer")
public class JobStartupQueuer {

    @Resource
    private Queue<Message> jobChannelQueue;

    public boolean accept(Message<?> message) {
        LOG.info("Channel size: {}", jobChannelQueue.size());
        return true;
    }
}

因此 jobChannelQueue 被注入，因此在您的 ServiceActivator 处理方法（例如接受）中，我们可以引用队列及其内部消息。

【讨论】：