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
