Merge pull request #26 from bltavares/public-api

Allow creating new Builders using BaseRecordBuilder

Author: AndrewJSchofield

src/main/java/com/ibm/eventstreams/connect/mqsource/builders/BaseRecordBuilder.java

@@ -85,7 +85,7 @@ else if (kh.equals(MQSourceConnector.CONFIG_VALUE_MQ_RECORD_BUILDER_KEY_HEADER_J
      * 
      * @throws JMSException      Message could not be converted
      */
-    SchemaAndValue getKey(JMSContext context, String topic, Message message) throws JMSException {
+    public SchemaAndValue getKey(JMSContext context, String topic, Message message) throws JMSException {
         Schema keySchema = null;
         Object key = null;
         String keystr;
@@ -134,7 +134,7 @@ SchemaAndValue getKey(JMSContext context, String topic, Message message) throws
      * 
      * @throws JMSException      Message could not be converted
      */
-    abstract SchemaAndValue getValue(JMSContext context, String topic, boolean messageBodyJms, Message message) throws JMSException;
+    public abstract SchemaAndValue getValue(JMSContext context, String topic, boolean messageBodyJms, Message message) throws JMSException;
 
    /**
      * Convert a message into a Kafka Connect SourceRecord.

src/main/java/com/ibm/eventstreams/connect/mqsource/builders/DefaultRecordBuilder.java

@@ -55,7 +55,7 @@ public DefaultRecordBuilder() {
      * 
      * @throws JMSException      Message could not be converted
      */
-    @Override SchemaAndValue getValue(JMSContext context, String topic, boolean messageBodyJms, Message message) throws JMSException {
+    @Override public SchemaAndValue getValue(JMSContext context, String topic, boolean messageBodyJms, Message message) throws JMSException {
         Schema valueSchema = null;
         Object value = null;
 

src/main/java/com/ibm/eventstreams/connect/mqsource/builders/JsonRecordBuilder.java

@@ -64,7 +64,7 @@ public JsonRecordBuilder() {
      * 
      * @throws JMSException      Message could not be converted
      */
-    @Override SchemaAndValue getValue(JMSContext context, String topic, boolean messageBodyJms, Message message) throws JMSException {
+    @Override public SchemaAndValue getValue(JMSContext context, String topic, boolean messageBodyJms, Message message) throws JMSException {
         byte[] payload;
 
         if (message instanceof BytesMessage) {
@@ -81,4 +81,4 @@ else if (message instanceof TextMessage) {
 
         return converter.toConnectData(topic, payload);
     }
-}
+}