Review Board 1.7.22


FLUME-1784: JMSource fix minor documentation problem and parameter name

Review Request #8607 - Created Dec. 14, 2012 and submitted

Brock Noland
trunk
FLUME-1784
Reviewers
Flume
flume-git
Fixes minor documentation problem and renames the converter parameter to be consistent with other components.
Unit tests pass.
flume-ng-doc/sphinx/FlumeUserGuide.rst
Revision 6490710 New Change
[20] 729 lines
[+20]
730
**destinationType**         --           Destination type (queue or topic)
730
**destinationType**         --           Destination type (queue or topic)
731
messageSelector             --           Message selector to use when creating the consumer
731
messageSelector             --           Message selector to use when creating the consumer
732
userName                    --           Username for the destination/provider
732
userName                    --           Username for the destination/provider
733
passwordFile                --           File containing the password for the destination/provider
733
passwordFile                --           File containing the password for the destination/provider
734
batchSize                   100          Number of messages to consume in one batch
734
batchSize                   100          Number of messages to consume in one batch
735
converter                   DEFAULT      Class to use to convert messages to flume events. See below.
735
converter.type              DEFAULT      Class to use to convert messages to flume events. See below.
736
converter.*                 --           Converter properties.
736
converter.*                 --           Converter properties.
737
converter.charset           UTF-8        Default converter only. Charset to use when converting JMS TextMessages to byte arrays.
737
converter.charset           UTF-8        Default converter only. Charset to use when converting JMS TextMessages to byte arrays.
738
=========================   ===========  ==============================================================
738
=========================   ===========  ==============================================================
739

    
   
739

   
740

    
   
740

   
[+20] [20] 7 lines
[+20]
748
BytesMessage:
748
BytesMessage:
749
  Bytes of message are copied to body of the FlumeEvent. Cannot convert more than 2GB
749
  Bytes of message are copied to body of the FlumeEvent. Cannot convert more than 2GB
750
  of data per message.
750
  of data per message.
751

    
   
751

   
752
TextMessage:
752
TextMessage:
753
  Text of message is converted to a UTF-8 byte array and copied to the body of the
753
  Text of message is converted to a byte array and copied to the body of the
754
  FlumeEvent.
754
  FlumeEvent. The default converter uses UTF-8 by default but this is configurable.
755

    
   
755

   
756
ObjectMessage:
756
ObjectMessage:
757
  Object is written out to a ByteArrayOutputStream wrapped in an ObjectOutputStream and
757
  Object is written out to a ByteArrayOutputStream wrapped in an ObjectOutputStream and
758
  the resulting array is copied to the body of the FlumeEvent.
758
  the resulting array is copied to the body of the FlumeEvent.
759

    
   
759

   
[+20] [20] 1996 lines
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
Revision e18b879 New Change
 
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSourceConfiguration.java
Revision 8a311c3 New Change
 
flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestJMSSource.java
Revision 617393c New Change
 
  1. flume-ng-doc/sphinx/FlumeUserGuide.rst: Loading...
  2. flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java: Loading...
  3. flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSourceConfiguration.java: Loading...
  4. flume-ng-sources/flume-jms-source/src/test/java/org/apache/flume/source/jms/TestJMSSource.java: Loading...