【发布时间】:2012-06-21 04:08:52
【问题描述】:
我在 ActiveMQ 中使用具有简单生产者和消费者的非持久主题。生产者有时可能处于空闲状态,不发送任何消息。
我想在消费者端检测到这一点(主题中没有消息)并通知用户。
我该怎么做?找不到这方面的任何信息。
谢谢 阿米特
【问题讨论】:
我在 ActiveMQ 中使用具有简单生产者和消费者的非持久主题。生产者有时可能处于空闲状态,不发送任何消息。
我想在消费者端检测到这一点(主题中没有消息)并通知用户。
我该怎么做?找不到这方面的任何信息。
谢谢 阿米特
【问题讨论】:
消费者订阅主题。如果消费者没有收到任何消息,则意味着生产者处于空闲状态。与队列不同,主题中的消息本质上是瞬态的(忽略持久订阅的细节)。
每次从主题收到消息时,让您的消费者更新时间戳。此外,有一个单独的线程定期监控时间戳,以通知用户时间戳是否早于 X 毫秒。
【讨论】: