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