Update SolaceInputPartitionReader.java

SravanThotakura05 · SravanThotakura05 · commit 748643f7a39a · 2025-03-27T15:58:57.000+05:30
diff --git a/pubsubplus-connector-spark_3.x/src/main/java/com/solacecoe/connectors/spark/streaming/partitions/SolaceInputPartitionReader.java b/pubsubplus-connector-spark_3.x/src/main/java/com/solacecoe/connectors/spark/streaming/partitions/SolaceInputPartitionReader.java
@@ -93,6 +93,9 @@ public SolaceInputPartitionReader(SolaceInputPartition inputPartition, boolean i
 
     @Override
     public boolean next() {
+        if(this.solaceBroker != null && this.solaceBroker.isException()) {
+            throw new SolaceSessionException(this.solaceBroker.getException());
+        }
         solaceMessage = getNextMessage();
         return solaceMessage != null;
     }

Original file line number	Diff line number	Diff line change
`@@ -93,6 +93,9 @@ public SolaceInputPartitionReader(SolaceInputPartition inputPartition, boolean i`
`93`	`93`
`94`	`94`	`@Override`
`95`	`95`	`public boolean next() {`
	`96`	`+ if(this.solaceBroker != null && this.solaceBroker.isException()) {`
	`97`	`+ throw new SolaceSessionException(this.solaceBroker.getException());`
	`98`	`+ }`
`96`	`99`	`solaceMessage = getNextMessage();`
`97`	`100`	`return solaceMessage != null;`
`98`	`101`	`}`