Edit documentation

Author: dardanxh

src/main/java/io/cdap/plugin/jms/sink/converters/RecordToBytesMessageConverter.java

@@ -25,7 +25,7 @@
 import javax.jms.JMSException;
 
 /**
- * A class with the functionality to convert StructuredRecords to BytesMessages
+ * A class with the functionality to convert StructuredRecords to BytesMessages.
  */
 public class RecordToBytesMessageConverter {
 

src/main/java/io/cdap/plugin/jms/sink/converters/RecordToMapMessageConverter.java

@@ -23,7 +23,7 @@
 import javax.jms.MapMessage;
 
 /**
- * A class with the functionality to convert StructuredRecords to MapMessages
+ * A class with the functionality to convert StructuredRecords to MapMessages.
  */
 public class RecordToMapMessageConverter {
 

src/main/java/io/cdap/plugin/jms/sink/converters/RecordToMessageConverter.java

@@ -23,7 +23,7 @@
 import javax.jms.Message;
 
 /**
- * A class with the functionality to convert StructuredRecords to Messages
+ * A class with the functionality to convert StructuredRecords to Messages.
  */
 public class RecordToMessageConverter {
 

src/main/java/io/cdap/plugin/jms/sink/converters/RecordToObjectMessageConverter.java

@@ -25,7 +25,7 @@
 import javax.jms.ObjectMessage;
 
 /**
- * A class with the functionality to convert StructuredRecords to ObjectMessages
+ * A class with the functionality to convert StructuredRecords to ObjectMessages.
  */
 public class RecordToObjectMessageConverter {
 

src/main/java/io/cdap/plugin/jms/sink/converters/RecordToTextMessageConverter.java

@@ -25,7 +25,7 @@
 import javax.jms.TextMessage;
 
 /**
- * A class with the functionality to convert StructuredRecords to TextMessages
+ * A class with the functionality to convert StructuredRecords to TextMessages.
  */
 public class RecordToTextMessageConverter {
 
@@ -73,7 +73,7 @@ private static TextMessage convertRecordWithSingleField(TextMessage textMessage,
    * @return a JMS text message
    */
   private static TextMessage convertRecordWithMultipleFields(TextMessage textMessage, StructuredRecord record) {
-    String body = null;
+    String body;
 
     try {
       body = StructuredRecordStringConverter.toJsonString(record);

src/main/java/io/cdap/plugin/jms/sink/converters/SinkMessageConverterFacade.java

@@ -29,7 +29,7 @@
 import javax.jms.TextMessage;
 
 /**
- * A facade class that provides the functionality to convert different type of JMS messages to structured records
+ * A facade class that provides the functionality to convert different type of JMS messages to structured records.
  */
 public class SinkMessageConverterFacade {
 

src/main/java/io/cdap/plugin/jms/source/JMSStreamingSource.java

@@ -33,8 +33,7 @@
 
 /**
  * This class <code>JMSStreamingSource</code> is a plugin that allows consuming messages from a specified JMS
- * Queue/Topic and generate
- * StructuredRecords out of them.
+ * Queue/Topic and generate StructuredRecords out of them.
  */
 @Plugin(type = StreamingSource.PLUGIN_TYPE)
 @Name("JMS")

src/main/java/io/cdap/plugin/jms/source/JMSStreamingSourceConfig.java

@@ -37,7 +37,7 @@
 import javax.annotation.Nullable;
 
 /**
- * Configs for {@link JMSStreamingSource}
+ * Configs for {@link JMSStreamingSource}.
  */
 public class JMSStreamingSourceConfig extends JMSConfig implements Serializable {
   // Params

src/main/java/io/cdap/plugin/jms/source/converters/BytesMessageToRecordConverter.java

@@ -34,7 +34,7 @@
 import javax.jms.MessageEOFException;
 
 /**
- * A class with the functionality to convert BytesMessages to StructuredRecords
+ * A class with the functionality to convert BytesMessages to StructuredRecords.
  */
 public class BytesMessageToRecordConverter {
 

src/main/java/io/cdap/plugin/jms/source/converters/MapMessageToRecordConverter.java

@@ -33,7 +33,7 @@
 import javax.jms.Message;
 
 /**
- * A class with the functionality to convert MapMessages to StructuredRecords
+ * A class with the functionality to convert MapMessages to StructuredRecords.
  */
 public class MapMessageToRecordConverter {
 

src/main/java/io/cdap/plugin/jms/source/converters/MessageToRecordConverter.java

@@ -27,7 +27,7 @@
 import javax.jms.Message;
 
 /**
- * A class with the functionality to convert Messages to StructuredRecords
+ * A class with the functionality to convert Messages to StructuredRecords.
  */
 public class MessageToRecordConverter {
 

src/main/java/io/cdap/plugin/jms/source/converters/ObjectMessageToRecordConverter.java

@@ -30,7 +30,7 @@
 import javax.jms.ObjectMessage;
 
 /**
- * A class with the functionality to convert ObjectMessages to StructuredRecords
+ * A class with the functionality to convert ObjectMessages to StructuredRecords.
  */
 public class ObjectMessageToRecordConverter {
 

src/main/java/io/cdap/plugin/jms/source/converters/SourceMessageConverterFacade.java

@@ -13,7 +13,7 @@
 import javax.jms.TextMessage;
 
 /**
- * A facade class that provides a single method to convert JMS messages to structured records
+ * A facade class that provides a single method to convert JMS messages to structured records.
  */
 public class SourceMessageConverterFacade {
 
@@ -23,12 +23,12 @@ public class SourceMessageConverterFacade {
    * @param message the incoming JMS message
    * @param config  the {@link JMSStreamingSourceConfig} with all user provided property values
    * @return the {@link StructuredRecord} built out of the JMS message fields
-   * @throws JMSException             in case the method fails to read fields from the JMS message
+   * @throws JMSException in case the method fails to read fields from the JMS message
    * @throws IllegalArgumentException in case the user provides a non-supported message type
    */
   public static StructuredRecord toStructuredRecord(Message message, JMSStreamingSourceConfig config)
     throws JMSException, IllegalArgumentException {
-    String messageType = null;
+    String messageType;
     if (!Strings.isNullOrEmpty(config.getMessageType())) {
       messageType = config.getMessageType();
     } else {

src/main/java/io/cdap/plugin/jms/source/converters/TextMessageToRecordConverter.java

@@ -27,7 +27,7 @@
 import javax.jms.TextMessage;
 
 /**
- * A class with the functionality to convert TextMessages to StructuredRecords
+ * A class with the functionality to convert TextMessages to StructuredRecords.
  */
 public class TextMessageToRecordConverter {