Fixed long running integration test

Author: SravanThotakura05

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

@@ -537,7 +537,7 @@ public void Should_Fail_If_CorrelationIdOffsetIsInvalid() {
     @Order(9)
     public void Should_Fail_If_ApplicationMessageIdOffsetIsInvalid() throws TimeoutException, StreamingQueryException {
         Path path = Paths.get("src", "test", "resources", "spark-checkpoint-1");
-//        assertThrows(StreamingQueryException.class, () -> {
+        assertThrows(StreamingQueryException.class, () -> {
             DataStreamReader reader = sparkSession.readStream()
                     .option(SolaceSparkStreamingProperties.HOST, solaceContainer.getOrigin(Service.SMF))
                     .option(SolaceSparkStreamingProperties.VPN, solaceContainer.getVpn())
@@ -557,7 +557,7 @@ public void Should_Fail_If_ApplicationMessageIdOffsetIsInvalid() throws TimeoutE
             StreamingQuery streamingQuery = dataset.writeStream().foreachBatch((VoidFunction2<Dataset<Row>, Long>) (dataset1, batchId) -> {
             }).start();
             streamingQuery.awaitTermination();
-//        });
+        });
     }
 
     @Test