Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implement stop() in reader container

Browse Source
This commit is contained in:
Soby Chacko
2023-02-17 12:11:04 -05:00
parent a32621315c
commit b53df99c1b
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-pulsar/src/main/java/org/springframework/pulsar/reader/DefaultPulsarReaderListenerContainer.java
View File

@@ -16,6 +16,7 @@
package org.springframework.pulsar.reader;
import java.io.IOException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
@@ -98,7 +99,14 @@ public class DefaultPulsarReaderListenerContainer<T> extends AbstractPulsarReade
@Override
protected void doStop() {
setRunning(false);
try {
this.logger.info("Closing this consumer.");
this.internalAsyncReader.get().reader.close();
}
catch (IOException e) {
this.logger.error(e, () -> "Error closing Pulsar Client.");
}
}
private void publishReaderStartingEvent() {