Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of torbjoern@gmail.com designates
 209.85.215.171 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=IhnrPtGlZYdRDCdn4UlPK5luWu0g8DQuR6xsk9wY1RVbl0FEbGzA7byUuknFTwUUDg
         EpNxvzlp7L0BZRAXHr/Aj9RinjDncGFh9ZUHg9Jd8Nkht6ZqK0WJeeZiAchmaGubHkVn
         wTrFrpbDU9E0ni1DKTjJoJr10zdnouCQhlWw8=
MIME-Version: 1.0
In-Reply-To: <AANLkTi=Us8m95R8ZV66GJGO4-FisZ4szJfCYZzfCEE0G@mail.gmail.com>
References: <29478980.post@talk.nabble.com>
	<AANLkTi=Us8m95R8ZV66GJGO4-FisZ4szJfCYZzfCEE0G@mail.gmail.com>
Date: Thu, 19 Aug 2010 21:30:45 +0200
Message-ID: <AANLkTi=tL-yEzrv2g4VzGzyFCx7vjFaYqdD6U8auG9aW@mail.gmail.com>
Subject: Re: How to get the consumer or producer's ip address?
From: Torbjorn Kristoffersen <torbjoern@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Thu, Aug 19, 2010 at 9:04 PM, Bruce Snyder <bruce.snyder@gmail.com> wrot=
e:
> On Thu, Aug 19, 2010 at 12:42 AM, oliver2010 <zzl_119@sina.com> wrote:
>>
>> 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
>> {
>> =A0 =A0class Program
>> =A0 =A0{
>> =A0 =A0 =A0 =A0static void Main(string[] args)
>> =A0 =A0 =A0 =A0{
>> =A0 =A0 =A0 =A0 =A0 =A0try
>> =A0 =A0 =A0 =A0 =A0 =A0{
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0//Create the Connection factory
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0IConnectionFactory factory =3D new
>> ConnectionFactory("tcp://192.168.7.51:61616/");
>>
>>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0//Create the connection
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0using (IConnection connection =3D factory=
.CreateConnection())
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0{
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0connection.ClientId =3D "monitor"=
;
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0connection.Start();
>>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0//Create the Session
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0using (ISession session =3D conne=
ction.CreateSession())
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0{
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0IDestination destination =
=3D
>> session.GetDestination("ActiveMQ.Advisory.Connection",DestinationType.To=
pic);
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0//Create the Consumer
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0IMessageConsumer consumer=
 =3D
>> session.CreateConsumer(destination);
>>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0consumer.Listener +=3D ne=
w
>> MessageListener(consumer_Listener);
>>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Console.ReadLine();
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0connection.Stop();
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0connection.Close();
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
>> =A0 =A0 =A0 =A0 =A0 =A0}
>> =A0 =A0 =A0 =A0 =A0 =A0catch (System.Exception e)
>> =A0 =A0 =A0 =A0 =A0 =A0{
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Console.WriteLine(e.Message);
>> =A0 =A0 =A0 =A0 =A0 =A0}
>> =A0 =A0 =A0 =A0}
>>
>> =A0 =A0 =A0 =A0static void consumer_Listener(IMessage message)
>> =A0 =A0 =A0 =A0{
>> =A0 =A0 =A0 =A0 =A0 =A0ActiveMQMessage msg =3D (ActiveMQMessage)message;
>> =A0 =A0 =A0 =A0 =A0 =A0Console.WriteLine(DateTime.Now.ToString() + " : "=
 +
>> msg.ToString());
>> =A0 =A0 =A0 =A0}
>> =A0 =A0}
>> }
>>
>> Result:
>>
>> 2010/8/19 11:00:06 : ActiveMQMessage[ commandId =3D 0, responseRe
>> roducerId =3D ID:DEV-01-3900-1282113492312-1:0:0:0, Destination =3D
>> .Advisory.Connection, TransactionId =3D , OriginalDestination =3D ,
>> EV-01-3900-1282113492312-1:0:0:0:23:34, OriginalTransactionId =3D
>> oupSequence =3D 0, CorrelationId =3D , Persistent =3D False, Expirati
>> =3D 0, ReplyTo =3D , Timestamp =3D 0, Type =3D Advisory, Content =3D , M=
a
>> s =3D System.Byte[], DataStructure =3D ConnectionInfo[ commandId =3D
>> ed =3D True, ConnectionId =3D ID:X-PC-1489-634178124065831258-1:0,
>> r, Password =3D , UserName =3D , BrokerPath =3D , BrokerMasterConnect
>> eable =3D False, ClientMaster =3D False ], TargetConsumerId =3D ID:X-
>> 065831258-1:0:1:1, Compressed =3D False, RedeliveryCounter =3D 0, B
>> ival =3D 0, UserID =3D , RecievedByDFBridge =3D False, Droppable =3D Fa
>> BrokerInTime =3D 1282186812265, BrokerOutTime =3D 1282186812265 ]
>>
>> ***********************************************************
>>
>> The question is i can't get the consumer't ip address? How to get it?
>
> There is nothing built in to JMS or ActiveMQ for this because it's not
> a concern of the broker or the JMS clients. But you can easily put the
> ip address in a header property or the message body.
>

That might not give you the correct IP, though.  It may not even be
possible to detect the IP.