activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: Interceptor to get messages text
Date Mon, 27 Dec 2010 15:53:47 GMT
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:  http://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 stored? I mean can
i intercept messages just when the lock is aquired and are ready 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: áhttp://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)
>> > á áthrows Exception {
>> >
>> > á á á á á á á á á á/*System.out.println("Message : " + message.toString());
>> >
>> > á á á á á á á á á áConfiguration conf = new Configuration();
>> > á á á á á á á á á á FileSystem fs = FileSystem.get(conf);
>> >
>> > á á á á á á á á á á Path filenamePath = new Path("hello.txt");
>> >
>> > á á á á á á á á á á try {
>> > á á á á á á á á á á á FSDataOutputStream out = fs.append(filenamePath);
>> > á á á á á á á á á á á System.out.println("Message Length : " + message.toString().length());
>> > á á á á á á á á á á á out.writeUTF(message.toString() );
>> > á á á á á á á á á á á out.close();}
>> > á á á á á á á á á á á catch (IOException ioe) {
>> > á á á á á á á á á á á á á System.err.println("IOException during
operation: " + ioe.toString());
>> > á á á á á á á á á á á á á System.exit(1);
>> > á á á á á á á á á á á á }
>> >
>> > á á á á á á á á á ásuper.send(producer, message);*/
>> > á á á á á á }
>> >
>> > }
>> >
>> >
>> > However what i do finally catch is at most an String of 806 characters like
this :
>> >
>> > Message : ActiveMQTextMessage {commandId = 5, responseRequired = false, messageId
= ID:dante-50013-1293033095353-0:1:1:1:1, originalDestination = null, originalTransactionId
= null, producerId = ID:dante-50013-1293033095353-0:1:1:1, destination = queue://TEST.FOO,
transactionId = null, expiration = 0, timestamp = 1293033095707, arrival = 0, brokerInTime
= 0, brokerOutTime = 0, correlationId = null, replyTo = null, 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 = false, readOnlyBody = false, droppable
= false, text = M}
>> >
>> > What I really want to get is the text field, but if the message size exceeds
a certain size then i cannot catch it? Any ideas?
>> >
>> > thanks,
>> > Petrucci
>> >
>

Mime
View raw message