Fix timestamp when publishing to Solace

Spark returns timestamp in micro seconds, which will cause timestamp parsing issues. Hence fixing it when publishing rather at consumption.

Author: SravanThotakura05

src/main/java/com/solacecoe/connectors/spark/streaming/partitions/SolaceInputPartitionReader.java

@@ -167,7 +167,7 @@ public InternalRow get() {
             SolaceRecord solaceRecord = SolaceRecord.getMapper(this.properties.getOrDefault(SolaceSparkStreamingProperties.OFFSET_INDICATOR, SolaceSparkStreamingProperties.OFFSET_INDICATOR_DEFAULT)).map(solaceMessage.bytesXMLMessage);
             long timestamp = solaceRecord.getSenderTimestamp();
             if (solaceRecord.getSenderTimestamp() == 0) {
-                timestamp = System.currentTimeMillis() / 1000;
+                timestamp = System.currentTimeMillis();
             }
             InternalRow row;
             if (this.includeHeaders) {

src/main/java/com/solacecoe/connectors/spark/streaming/solace/SolaceBroker.java

@@ -420,7 +420,7 @@ public XMLMessage createMessage(String applicationMessageId, String partitionKey
         xmlMessage.setCorrelationId(applicationMessageId);
         xmlMessage.setApplicationMessageId(applicationMessageId);
         if (timestamp > 0L) {
-            xmlMessage.setSenderTimestamp(timestamp);
+            xmlMessage.setSenderTimestamp(timestamp / 1000);
         }
         xmlMessage.setDeliveryMode(DeliveryMode.PERSISTENT);