[SECIOTSRK-297] Fix issue with PublishingWrapper

diff --git a/servermq/src/main/java/com/samsung/servermq/iotivity/MessageQueuePublisher.java b/servermq/src/main/java/com/samsung/servermq/iotivity/MessageQueuePublisher.java
index 18f95d8..2453eb1 100644 (file)
--- a/servermq/src/main/java/com/samsung/servermq/iotivity/MessageQueuePublisher.java
+++ b/servermq/src/main/java/com/samsung/servermq/iotivity/MessageQueuePublisher.java
@@ -27,7 +27,10 @@ public class MessageQueuePublisher {
                        byte[] data = cbor.encodingPayloadToCbor(messageMap);
                        KafkaProducerWrapper mKafkaProducerOperator = new KafkaProducerWrapper(kafkaBrokerHost,
                                topicName);
-                       result = mKafkaProducerOperator.publishMessage(data);
+                       if(mKafkaProducerOperator.publishMessage(data)){
+                               result = true;
+                               mKafkaProducerOperator.closeConnection();
+                       }
                        log.info("Message publish to " + topicName + " : " + new String(data));
                } catch (Exception e) {
                        log.error(e.getMessage(), e);