Fix SonarLint issues

Author: SravanThotakura05

pubsubplus-connector-spark_3.x/src/docs/sections/general/configuration/spark-config.adoc

@@ -55,7 +55,7 @@
 | int
 | 0 - 60000
 | 3000
-| How much time in (MS) to wait between each attempt to connect or reconnect to a host. If a connect or reconnect attempt to host is not successful, the API waits for the amount of time set for reconnectRetryWaitInMillis, and then makes another connect or reconnect attempt.
+| How much time in (MS) to wait between each attempt to connect or reconnect to a host. If connect or reconnect attempt to host is not successful, the API waits for the amount of time set for reconnectRetryWaitInMillis, and then makes another connect or reconnect attempt.
 
 | solace.apiProperties.<Property>
 | any

pubsubplus-connector-spark_3.x/src/main/java/com/solacecoe/connectors/spark/streaming/solace/SolaceBroker.java

@@ -29,7 +29,6 @@ public class SolaceBroker implements Serializable {
     private boolean isAccessTokenSourceModified = true;
     private boolean isOAuth = false;
     private final Map<String, String> properties;
-    private boolean initiateReplay = false; // required when multiple consumers bind to a queue.
     public SolaceBroker(Map<String, String> properties, boolean initiateReplay) {
         eventListeners = new CopyOnWriteArrayList<>();
         flowReceivers = new CopyOnWriteArrayList<>();
@@ -151,7 +150,6 @@ private void setReceiver(EventListener eventListener) {
 
             flowProp.setEndpoint(listenQueue);
             if(replayStart != null) {
-                this.initiateReplay = true;
                 flowProp.setReplayStartLocation(replayStart);
             }
             flowProp.setAckMode(JCSMPProperties.SUPPORTED_MESSAGE_ACK_CLIENT);
@@ -166,7 +164,6 @@ private void setReceiver(EventListener eventListener) {
             log.info("SolaceSparkConnector - Consumer flow started to listen for messages on queue {} ", this.queue);
             flowReceivers.add(cons);
         } catch (Exception e) {
-            this.initiateReplay = false;
             handleException("SolaceSparkConnector - Consumer received exception. Shutting down consumer ", e);
         }
     }

pubsubplus-connector-spark_3.x/src/test/java/com/solacecoe/connectors/spark/SolaceSparkStreamingMessageReplayIT.java

@@ -23,7 +23,6 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.sql.Timestamp;
-import java.text.Format;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.TimeZone;
@@ -34,7 +33,7 @@
 @Testcontainers
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 @TestMethodOrder(MethodOrderer.OrderAnnotation.class)
-public class SolaceSparkStreamingMessageReplayIT {
+class SolaceSparkStreamingMessageReplayIT {
     private SempV2Api sempV2Api = null;
     private SolaceContainer solaceContainer = new SolaceContainer("solace/solace-pubsub-standard:latest").withExposedPorts(8080, 55555);
     private SparkSession sparkSession;
@@ -111,7 +110,7 @@ public void handleErrorEx(Object o, JCSMPException e, long l) {
 
     @Test
     @Order(1)
-    public void Should_ProcessData() throws TimeoutException, StreamingQueryException {
+    void Should_ProcessData() throws TimeoutException, StreamingQueryException {
         Path path = Paths.get("src", "test", "resources", "spark-checkpoint-1");
 //        SparkSession sparkSession = SparkSession.builder()
 //                .appName("data_source_test")
@@ -175,7 +174,7 @@ public void Should_ProcessData() throws TimeoutException, StreamingQueryExceptio
 
     @Test
     @Order(2)
-    public void Should_InitiateReplay_ALL_STRATEGY_And_ProcessData() throws TimeoutException, StreamingQueryException {
+    void Should_InitiateReplay_ALL_STRATEGY_And_ProcessData() throws TimeoutException, StreamingQueryException {
         Path path = Paths.get("src", "test", "resources", "spark-checkpoint-1");
 //        SparkSession sparkSession = SparkSession.builder()
 //                .appName("data_source_test")
@@ -229,7 +228,7 @@ public void Should_InitiateReplay_ALL_STRATEGY_And_ProcessData() throws TimeoutE
 
     @Test
     @Order(3)
-    public void Should_InitiateReplay_TIMEBASED_STRATEGY_And_ProcessData() throws TimeoutException, StreamingQueryException {
+    void Should_InitiateReplay_TIMEBASED_STRATEGY_And_ProcessData() throws TimeoutException, StreamingQueryException {
         Path path = Paths.get("src", "test", "resources", "spark-checkpoint-1");
 //        SparkSession sparkSession = SparkSession.builder()
 //                .appName("data_source_test")
@@ -284,7 +283,7 @@ public void Should_InitiateReplay_TIMEBASED_STRATEGY_And_ProcessData() throws Ti
 
     @Test
     @Order(4)
-    public void Should_InitiateReplay_REPLICATIONGROUPMESSAGEID_STRATEGY_And_ProcessData() throws TimeoutException, StreamingQueryException {
+    void Should_InitiateReplay_REPLICATIONGROUPMESSAGEID_STRATEGY_And_ProcessData() throws TimeoutException, StreamingQueryException {
         Path path = Paths.get("src", "test", "resources", "spark-checkpoint-1");
 //        SparkSession sparkSession = SparkSession.builder()
 //                .appName("data_source_test")