現在、このクラスを使用しています：
- com.trendrr.nsq.NSQProducer
- com.trendrr.nsq.NSQConsumer
私のサービスは、現時点でキューに入れられているメッセージの数を知る必要があります。これは、「いつ完了するか」の推定方法があるためです。
誰かが実際のキューサイズを取得する方法を知っていますか? おそらく他のJava実装で？
私が見つけたもの：
- https://github.com/brainlag/JavaNSQClient (コンシューマには getTotalMessages() メソッドがありますが、これは処理されたメッセージ カウンタの合計です)