时间戳

首页 > 解决方案 > StatisticsPlugin 中“大小”的值始终为 0

jms - StatisticsPlugin 中“大小”的值始终为 0

问题描述

我正在使用 ActiveMQ 5.15.11，并且我正在尝试使用StatisticsPlugin插件以编程方式获取待处理消息的数量。

以下是用于创建和发送消息的代码ActiveMQ.Statistics.Broker：

public void produceMessage(String queueName, String message, boolean replyToTempQueue) throws JMSException {

    // Create a connection factory.
    final ActiveMQConnectionFactory connectionFactory =
        new ActiveMQConnectionFactory(System.getenv("WIRE_LEVEL_ENDPOINT"));

    // Pass the username and password.
    connectionFactory.setUserName(System.getenv("ACTIVE_MQ_USERNAME"));
    connectionFactory.setPassword(System.getenv("ACTIVE_MQ_PASSWORD"));

    // Create a pooled connection factory.
    final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
    pooledConnectionFactory.setConnectionFactory(connectionFactory);
    pooledConnectionFactory.setMaxConnections(10);

    // Establish a connection for the producer.
    final Connection producerConnection = pooledConnectionFactory.createConnection();
    producerConnection.start();

    // Create a session.
    final Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    // Create a queue named "MyQueue".
    final ActiveMQQueue producerDestination = (ActiveMQQueue) producerSession.createQueue(queueName);

    // Create a producer from the session to the queue.
    final MessageProducer producer = producerSession.createProducer(producerDestination);
    producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

    // Create a message.
    Message producerMessage = null;

    // Add a reply to queue if one has been provided.
    if (replyToTempQueue) {
      producerMessage = producerSession.createMapMessage();
      producerMessage.setJMSReplyTo(producerSession.createTemporaryQueue());
    } else {
      producerMessage = producerSession.createTextMessage(message);
    }

    // Send the message.
    producer.send(producerMessage);
    System.out.println("Message sent.");
    producer.close();
    producerSession.close();
    producerConnection.close();
  }

但是，它总是显示大小为 0。这是为什么呢？

ActiveMQMapMessage {commandId = 6, responseRequired = false, messageId = ID:DESKTOP-CQNTDSL-64043-1583929718154-177:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:DESKTOP-CQNTDSL-64043-1583929718154-177:1:1:1, destination = queue://ActiveMQ.Statistics.Broker, transactionId = null, expiration = 0, timestamp = 1583946785436, arrival = 0, brokerInTime = 1583946785552, brokerOutTime = 1583946785811, correlationId = null, replyTo = temp-queue://ID:DESKTOP-CQNTDSL-64043-1583929718154-177:1:1, persistent = false, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false} ActiveMQMapMessage{ theTable = {} }

标签： jmsactivemq

解决方案

您正在查看的size并不表示代理中待处理消息的数量。您需要检查enqueueCount值而不是size. 根据文档，查询时会返回此值ActiveMQ.Statistics.Broker。

您还可以通过查询获取特定目的地的数据ActiveMQ.Statistics.Destination。从文档：

...要查询目的地的统计信息，只需向以 . 开头的目的地名称发送消息ActiveMQ.Statistics.Destination。例如，要检索名称为 的队列的统计信息TEST.FOO，请将空消息发送到名为ActiveMQ.Statistics.Destination.TEST.FOO...

推荐阅读