我现在正在使用这个类:
- com.trendrr.nsq.NSQProducer
- com.trendrr.nsq.NSQConsumer
我的服务需要知道目前有多少消息排队,因为有一些“何时完成”的估计方法。
有人知道如何获得实际的队列大小吗?也许与其他一些java实现?
我发现了什么:
- https://github.com/brainlag/JavaNSQClient(消费者有一些 getTotalMessages() 方法,但它是一个总处理的 msg 计数器)
我现在正在使用这个类:
我的服务需要知道目前有多少消息排队,因为有一些“何时完成”的估计方法。
有人知道如何获得实际的队列大小吗?也许与其他一些java实现?
我发现了什么: