Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of chubrilo@gmail.com designates
 209.85.215.43 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:sender:in-reply-to:references:date
         :x-google-sender-auth:message-id:subject:from:to:content-type
         :content-transfer-encoding;
        b=P/OfYhwd8+8YpHuf5AKOM4OEU4//huhzS3WYjjzo2LPNInErTvxG7qSAabxVPz7zy2
         3pUyYGKMjJRfVlQX2Q2lsjN3y+6b0jhetmZcYRX2u1LAJ4Jc6G3Bx1Ew5lZr/i6Gl82P
         CppBbKcdFAqkCE5LUv5UHYySSmUnS3WAYPRHM=
MIME-Version: 1.0
Sender: chubrilo@gmail.com
In-Reply-To: <SNT128-W527E47C45A5BF8DD86130898000@phx.gbl>
References: <SNT128-W42C40E934E154CD9C1033A981B0@phx.gbl>
	<AANLkTikNzu_Q2zUZTnyFuJdLvhMh9c4xPp7hHxjLmOnN@mail.gmail.com>
	<SNT128-W527E47C45A5BF8DD86130898000@phx.gbl>
Date: Mon, 27 Dec 2010 16:53:47 +0100
Message-ID: <AANLkTi=kBEyeYvWR=6NJHPtwLVBHjE5WfRiGNOjea9Ba@mail.gmail.com>
Subject: Re: Interceptor to get messages text
From: Dejan Bosanac <dejan@nighttale.net>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

I didn't realize that you want to intercept messages before they are
added to the broker. In case you just want to "log" all the messages
that comes to the destination, you can use Camel to easily do that.
For queues, you can use "mirrored queues"
http://activemq.apache.org/mirrored-queues.html


Cheers
--
Dejan Bosanac
-----------------
FuseSource - The experts in open source integration and messaging.
Email: dejanb@fusesource.com
Web: http://fusesource.com
Twitter: =A0http://twitter.com/dejanb
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net


On Mon, Dec 27, 2010 at 1:22 PM, Petrucci Andreas
<petrucci_2005@hotmail.com> wrote:
>
> Two questions:
>
> what do you mean better ways???
>
> Is there a way to intercept a message just before it is permanently store=
d? I mean can i intercept messages just when the lock is aquired and are re=
ady to permanently stored in amq or kahadb??
>
> thnx,
> Petrucci
>
>> Date: Wed, 22 Dec 2010 17:30:46 +0100
>> Subject: Re: Interceptor to get messages text
>> From: dejan@nighttale.net
>> To: users@activemq.apache.org
>>
>> Hi,
>>
>> try
>>
>> ((TextMessage)message).getText()
>>
>> but there are better ways to achieve what your code is doing here.
>>
>> Cheers
>> --
>> Dejan Bosanac
>> -----------------
>> FuseSource - The experts in open source integration and messaging.
>> Email: dejanb@fusesource.com
>> Web: http://fusesource.com
>> Twitter: =E1http://twitter.com/dejanb
>> ActiveMQ in Action - http://www.manning.com/snyder/
>> Blog - http://www.nighttale.net
>>
>>
>>
>> 2010/12/22 Petrucci Andreas <petrucci_2005@hotmail.com>:
>> >
>> > Hi there, i have constructed an interceptor in order to get producers =
messages. the code is below.
>> >
>> > public class mypluginBroker extends BrokerFilter {
>> >
>> > public void send(ProducerBrokerExchange producer, Message message)
>> > =E1 =E1throws Exception {
>> >
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1/*System.out.println("Message :=
 " + message.toString());
>> >
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1Configuration conf =3D new Conf=
iguration();
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 FileSystem fs =3D FileSystem.g=
et(conf);
>> >
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 Path filenamePath =3D new Path=
("hello.txt");
>> >
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 try {
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 FSDataOutputStream out =3D=
 fs.append(filenamePath);
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 System.out.println("Messag=
e Length : " + message.toString().length());
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 out.writeUTF(message.toStr=
ing() );
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 out.close();}
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 catch (IOException ioe) {
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 System.err.println=
("IOException during operation: " + ioe.toString());
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 System.exit(1);
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 }
>> >
>> > =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1 =E1super.send(producer, message);*=
/
>> > =E1 =E1 =E1 =E1 =E1 =E1 }
>> >
>> > }
>> >
>> >
>> > However what i do finally catch is at most an String of 806 characters=
 like this :
>> >
>> > Message : ActiveMQTextMessage {commandId =3D 5, responseRequired =3D f=
alse, messageId =3D ID:dante-50013-1293033095353-0:1:1:1:1, originalDestina=
tion =3D null, originalTransactionId =3D null, producerId =3D ID:dante-5001=
3-1293033095353-0:1:1:1, destination =3D queue://TEST.FOO, transactionId =
=3D null, expiration =3D 0, timestamp =3D 1293033095707, arrival =3D 0, bro=
kerInTime =3D 0, brokerOutTime =3D 0, correlationId =3D null, replyTo =3D n=
ull, persistent =3D false, type =3D null, priority =3D 4, groupID =3D null,=
 groupSequence =3D 0, targetConsumerId =3D null, compressed =3D false, user=
ID =3D null, content =3D null, marshalledProperties =3D null, dataStructure=
 =3D null, redeliveryCounter =3D 0, size =3D 0, properties =3D null, readOn=
lyProperties =3D false, readOnlyBody =3D false, droppable =3D false, text =
=3D M}
>> >
>> > What I really want to get is the text field, but if the message size e=
xceeds a certain size then i cannot catch it? Any ideas?
>> >
>> > thanks,
>> > Petrucci
>> >
>