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.

Constructor Summary

Constructors

Constructor and Description
JMSTextMessageTransformer()

Method Summary

Modifier and Type	Method and Description
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

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

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:

adaptor id

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 - if there is problem process message