org.apache.hadoop.chukwa.datacollection.adaptor.jms
Class JMSTextMessageTransformer

java.lang.Object
  org.apache.hadoop.chukwa.datacollection.adaptor.jms.JMSTextMessageTransformer

All Implemented Interfaces:

JMSMessageTransformer

public class JMSTextMessageTransformer
extends Object
implements JMSMessageTransformer

Basic JMSMessageTransformer that uses the payload message of a JMS TextMessage as the Chukwa record payload. If the message is not an instance of TextMessage, or it is, but the payload is null or empty, returns null.

Field Summary

protected org.apache.commons.logging.Log

log

Constructor Summary

JMSTextMessageTransformer()

Method Summary

String	parseArgs(String s) Parse any transformer-specific args to initialize the transformer.
byte[]	transform(javax.jms.Message message) Transform a Message to an array of bytes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected org.apache.commons.logging.Log log

Constructor Detail

JMSTextMessageTransformer

public JMSTextMessageTransformer()

Method Detail

parseArgs

public String parseArgs(String s)

Description copied from interface: JMSMessageTransformer

Parse any transformer-specific args to initialize the transformer. Return a null if the arguments could not be parsed. This method will always be invoked before transform is called only if transformer arguments were passed. If they weren't, this method will never be called.

Specified by:

parseArgs in interface JMSMessageTransformer

Parameters:

s - Arguments needed to configur the transformer.

Returns:

transform

public byte[] transform(javax.jms.Message message)
                 throws javax.jms.JMSException

Description copied from interface: JMSMessageTransformer

Transform a Message to an array of bytes. Return null for a message that should be ignored.

Specified by:

transform in interface JMSMessageTransformer

Parameters:

message - JMS message received by a JMS Adaptor.

Returns:

the bytes that should be bound to the Chukwa chunk.

Throws:

javax.jms.JMSException