fix: incorrect datatype in config

Signed-off-by: A S Adil Mohammad <[email protected]>

Author: A S Adil Mohammad

src/integration/java/com/ibm/eventstreams/connect/mqsink/MQSinkTaskIT.java

@@ -127,6 +127,44 @@ public void verifyStringMessages() throws JMSException {
         assertEquals("world", messagesInMQ.get(1).getBody(String.class));
     }
 
+    @Test
+    public void verifyMqConfig() throws JMSException {
+        final MQSinkTask newConnectTask = new MQSinkTask();
+
+        // configure a sink task for string messages
+        final Map<String, String> connectorConfigProps = createDefaultConnectorProperties();
+        connectorConfigProps.put("mq.message.builder",
+                DEFAULT_MESSAGE_BUILDER);
+
+        connectorConfigProps.put("mq.ssl.use.ibm.cipher.mappings",
+                "true");        
+
+        // start the task so that it connects to MQ
+        newConnectTask.start(connectorConfigProps);
+
+        // create some test messages
+        final List<SinkRecord> records = new ArrayList<>();
+        records.add(generateSinkRecord(null, "hello"));
+        records.add(generateSinkRecord(null, "world"));
+        newConnectTask.put(records);
+
+        // flush the messages
+        final Map<TopicPartition, OffsetAndMetadata> offsets = new HashMap<>();
+        final TopicPartition topic = new TopicPartition(TOPIC, PARTITION);
+        final OffsetAndMetadata offset = new OffsetAndMetadata(commonOffset);
+        offsets.put(topic, offset);
+        newConnectTask.flush(offsets);
+
+        // stop the task
+        newConnectTask.stop();
+
+        // verify that the messages were successfully submitted to MQ
+        final List<Message> messagesInMQ = getAllMessagesFromQueue(DEFAULT_SINK_QUEUE_NAME);
+        assertEquals(2, messagesInMQ.size());
+        assertEquals("hello", messagesInMQ.get(0).getBody(String.class));
+        assertEquals("world", messagesInMQ.get(1).getBody(String.class));
+    }
+
     @Test
     public void verifyStringJmsMessages() throws JMSException {
         final MQSinkTask newConnectTask = new MQSinkTask();

src/main/java/com/ibm/eventstreams/connect/mqsink/JMSWorker.java

@@ -102,7 +102,7 @@ public void configure(final AbstractConfig config) throws ConnectException {
         mqConnectionHelper = new MQConnectionHelper(config);
 
         if (mqConnectionHelper.getUseIBMCipherMappings() != null) {
-            System.setProperty("com.ibm.mq.cfg.useIBMCipherMappings", mqConnectionHelper.getUseIBMCipherMappings());
+            System.setProperty("com.ibm.mq.cfg.useIBMCipherMappings", Boolean.toString(mqConnectionHelper.getUseIBMCipherMappings()));
         }
 
         try {

src/main/java/com/ibm/eventstreams/connect/mqsink/MQConnectionHelper.java

@@ -63,8 +63,8 @@ public Boolean isPersistent() {
         return config.getBoolean(MQSinkConfig.CONFIG_NAME_MQ_PERSISTENT);
     }
 
-    public String getUseIBMCipherMappings() {
-        return config.getString(MQSinkConfig.CONFIG_NAME_MQ_SSL_USE_IBM_CIPHER_MAPPINGS);
+    public Boolean getUseIBMCipherMappings() {
+        return config.getBoolean(MQSinkConfig.CONFIG_NAME_MQ_SSL_USE_IBM_CIPHER_MAPPINGS);
     }
 
     public int getTransportType() {