[
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.
