Skip to content

Commit 316ced0

Browse files
Improved Integration tests runtime
1 parent 31b875d commit 316ced0

File tree

3 files changed

+540
-454
lines changed

3 files changed

+540
-454
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -213,6 +213,7 @@ public void closeReceivers() {
213213
flowReceivers.forEach(flowReceiver -> {
214214
if(flowReceiver != null && !flowReceiver.isClosed()) {
215215
String endpoint = flowReceiver.getEndpoint().getName();
216+
flowReceiver.stop();
216217
flowReceiver.close();
217218
log.info("SolaceSparkConnector - Closed flow receiver to endpoint {}", endpoint);
218219
}

0 commit comments

Comments
 (0)