如何访问.net中的activemq统计信息插件 [英] how to access the activemq statistics plugin in .net

问题描述

我正在尝试访问activemq统计信息 http://activemq.apache.org/statisticsplugin.html 在c＃

I am trying to access the activemq statistics information http://activemq.apache.org/statisticsplugin.html in c#

这是我到目前为止所拥有的。我无法从消费者那里得到答复。我可以在监视器网站上为队列增加计数。

This is what i have so far. I am not able to get a reply from the consumer. I can the count increase in monitor website for the queue.

public class Statistics 
{
    private readonly string queueName = string.Empty;
    private readonly string queueToMonitor = string.Empty; 
    private readonly IConnectionFactory connectionFactory;
    private readonly IConnection connection;
    private readonly ISession session;
    private readonly IMessageProducer producer;
    private readonly ActiveMQQueue queue;


    public Statistics(string qName, string brokerUri, string queueToMon)
    {
        this.queueName = qName;
        this.queueToMonitor = "ActiveMQ.Statistics.Destination." + queueToMon; 
        this.connectionFactory = new ConnectionFactory(brokerUri);
        this.connection = connectionFactory.CreateConnection();
        this.connection.Start();
        this.session = connection.CreateSession();

        queue = new ActiveMQQueue(qName);
        producer = session.CreateProducer(queue);

    }

    public void GetStats()
    {
        try
        {
            var statusQueue = session.CreateTemporaryQueue();
            var consumer = session.CreateConsumer(statusQueue);
            ActiveMQQueue query = new ActiveMQQueue(queueToMonitor);

            var msg = session.CreateMessage();
            msg.NMSReplyTo = statusQueue;
            producer.Send(queue, msg);

            var reply = (ActiveMQMapMessage)consumer.Receive();

            if (reply != null)
            {
                var test = reply.Content.ToString(); 
            }
         }
        catch (Exception e)
        {
            var t = e.Message + " " + e.StackTrace;
        }

    }
}

推荐答案

您正在将邮件发送到错误的队列。您需要将邮件发送到 ActiveMQ.Statistics.Destination.QueueToMonitor 目标。我重新编写了您的GetStats（）函数以表明它可以正常工作。关键的更改是生产者将消息发送到的目的地。

You are sending the message to the wrong queue. You need to send the message to the ActiveMQ.Statistics.Destination.QueueToMonitor destination. I re-wrote your GetStats() function to show that it works. The critical change is which destination the producer sends the message to.

public void GetStats()
{
    try
    {
        IDestination statusQueue = session.CreateTemporaryQueue();
        IMessageConsumer consumer = session.CreateConsumer(statusQueue);
        IDestination query = session.GetQueue(queueToMonitor);
        IMessage msg = session.CreateMessage();
        IMessageProducer producer = session.CreateProducer(query);

        msg.NMSReplyTo = statusQueue;
        producer.Send(msg);

        IMapMessage reply = (IMapMessage) consumer.Receive();

        if(reply != null)
        {
            IPrimitiveMap statsMap = reply.Body;

            foreach(string statKey in statsMap.Keys)
            {
                Console.WriteLine("{0} = {1}", statKey, statsMap[statKey]);
            }
        }
    }
    catch(Exception e)
    {
        var t = e.Message + " " + e.StackTrace;
    }
}

这篇关于如何访问.net中的activemq统计信息插件的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！