chukwa-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bill Graham (JIRA)" <>
Subject [jira] Commented: (CHUKWA-469) Create a JMSAdaptor
Date Fri, 02 Apr 2010 00:39:27 GMT


Bill Graham commented on CHUKWA-469:

Please comment with any suggestions. This is what I'm thinking:

- {{oah.chukwa.datacollection.adaptor.jms}}
This is the package where the code will live. Creating a new package since there will be a
couple of related classes.

- {{JMSAdaptor}}
This is the main class that will connect to a JMS topic, listen for messages and add chunks
to the receiver. It uses a {{JMSMessageTransformer}} to transform the message to a byte array.

- {{JMSMessageTransformer}}
An interface that knows how to transform a {{JMSMessage}} into a byte array with the following
  {{public byte[] transform(javax.jms.Message message)}}

- {{JMSTextMessageTransformer}}
This will be the default transformer, which transforms a {{javax.jms.TextMessage}}'s payload
into a byte array

- {{JMSMessagePropertyTransformer}}
This is what I'd personally need so I might add this as well. It takes a collection of ordered
message property names and a delimiter and returns a byte array made using the corresponding
property values.

- Configuration would look something like this:
{{add JMSAdaptor <dataType> <brokerURL> -t <topicName> [-s <JMSSelector>]
[-x <transformerName>] [-p <transformerProperties>] <offset>}}

- New dependancies
Sun's JMS
Sun's J2EE Management
Apache ActiveMQ
Apache Commons Pool

This first pass would only work with a topic but subsequent releases could work with a queue
if the need arises. The selector is to filter on certain types of messages. {{TransformerName}}
is to override the default transformer and {{transformerProperties}} is whatever properties
it takes.

> Create a JMSAdaptor
> -------------------
>                 Key: CHUKWA-469
>                 URL:
>             Project: Hadoop Chukwa
>          Issue Type: New Feature
>            Reporter: Bill Graham
>            Assignee: Bill Graham
> We should have a JMSAdaptor that listens to a JMS queue for messages to send to a collector.

This message is automatically generated by JIRA.
You can reply to this email to add a comment to the issue online.

View raw message