activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oliver2010 <zzl_...@sina.com>
Subject Re: About Using Advisory Messages In .net
Date Thu, 19 Aug 2010 03:02:09 GMT

I create a MessageConsumer that listens on the advisory topic.

Code:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Apache.NMS;
using Apache.NMS.ActiveMQ;
using Apache.NMS.ActiveMQ.Commands;
using System.IO;
using System.Xml.Serialization;
using System.Runtime.Serialization.Formatters.Binary;

namespace Monitor
{
    class Program
    {
        static void Main(string[] args)
        {
            try
            {
                //Create the Connection factory   
                IConnectionFactory factory = new
ConnectionFactory("tcp://192.168.7.51:61616/");


                //Create the connection   
                using (IConnection connection = factory.CreateConnection())
                {
                    connection.ClientId = "monitor";
                    connection.Start();

                    //Create the Session   
                    using (ISession session = connection.CreateSession())
                    {
                        IDestination destination =
session.GetDestination("ActiveMQ.Advisory.Connection",DestinationType.Topic);
                        //Create the Consumer   
                        IMessageConsumer consumer =
session.CreateConsumer(destination);

                        consumer.Listener += new
MessageListener(consumer_Listener);

                        Console.ReadLine();
                    }
                    connection.Stop();
                    connection.Close();
                }
            }
            catch (System.Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }

        static void consumer_Listener(IMessage message)
        {
            ActiveMQMessage msg = (ActiveMQMessage)message;
            Console.WriteLine(DateTime.Now.ToString() + " : " +
msg.ToString());
        }
    }
}

Result:

2010/8/19 11:00:06 : ActiveMQMessage[ commandId = 0, responseRe
roducerId = ID:DEV-01-3900-1282113492312-1:0:0:0, Destination =
.Advisory.Connection, TransactionId = , OriginalDestination = ,
EV-01-3900-1282113492312-1:0:0:0:23:34, OriginalTransactionId =
oupSequence = 0, CorrelationId = , Persistent = False, Expirati
= 0, ReplyTo = , Timestamp = 0, Type = Advisory, Content = , Ma
s = System.Byte[], DataStructure = ConnectionInfo[ commandId =
ed = True, ConnectionId = ID:X-PC-1489-634178124065831258-1:0,
r, Password = , UserName = , BrokerPath = , BrokerMasterConnect
eable = False, ClientMaster = False ], TargetConsumerId = ID:X-
065831258-1:0:1:1, Compressed = False, RedeliveryCounter = 0, B
ival = 0, UserID = , RecievedByDFBridge = False, Droppable = Fa
BrokerInTime = 1282186812265, BrokerOutTime = 1282186812265 ]

***********************************************************

The question is i can't get the consumer't ip address? How to get it?
-- 
View this message in context: http://old.nabble.com/About-Using-Advisory-Messages-In-.net-tp29449308p29477957.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message