[jira] Commented: (CHUKWA-469) Create a JMSAdaptor

["Bill Graham (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CHUKWA-469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12852623#action_12852623 ] 

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 method:
  {{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: https://issues.apache.org/jira/browse/CHUKWA-469
>             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.