通过计时器每秒记录一次 apache camel seda 队列深度
Log apache camel seda queue depth every second via a timer
如何在计时器上每秒记录实际的 seda 队列深度。
例如
from("seda:messageParser?concurrentConsumers=5&size=5000)
.process(messageProcessor)
from("timer://sedaQueueDepthLogger?fixedRate=true")
.to(LOG_SEDA_QUEUE_DEPTH)
上面 LOG_SEDA_QUEUE_DEPTH 应该是什么来实现这个？
你不能那么容易地记录它。从自定义处理器中，您可以获得 seda 端点，从那里您可以 APIs 获取队列，并获取大小，然后您可以记录。
还有 JMX API 可以找到该信息。
如何在计时器上每秒记录实际的 seda 队列深度。 例如
from("seda:messageParser?concurrentConsumers=5&size=5000)
.process(messageProcessor)
from("timer://sedaQueueDepthLogger?fixedRate=true")
.to(LOG_SEDA_QUEUE_DEPTH)
上面 LOG_SEDA_QUEUE_DEPTH 应该是什么来实现这个？
你不能那么容易地记录它。从自定义处理器中，您可以获得 seda 端点，从那里您可以 APIs 获取队列，并获取大小，然后您可以记录。
还有 JMX API 可以找到该信息。