Fix retrieving existing connection

Author: SravanThotakura05

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

@@ -90,6 +90,7 @@ public SolaceInputPartitionReader(SolaceInputPartition inputPartition, boolean i
 
         // Get existing connection if a new task is scheduled on executor or create a new one
         if (SolaceConnectionManager.getConnection(inputPartition.getId()) != null) {
+            solaceBroker = SolaceConnectionManager.getConnection(inputPartition.getId());
             if (closeReceiversOnPartitionClose) {
                 createReceiver(inputPartition.getId(), ackLastProcessedMessages);
             }