GH-777: Reset running on stop()

garyrussell · garyrussell · commit 5024a77aa4b3 · 2018-08-21T15:30:58.000-04:00
Fixes #777 So that `isRunning()` properly reflects the state. In future, consider removing `Lifecycle` and close the producer(s) with a `ContextStoppedEvent`.
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java b/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java
@@ -189,6 +189,7 @@ public void start() {
 	public void stop() {
 		try {
 			destroy();
+			this.running = false;
 		}
 		catch (Exception e) {
 			logger.error("Exception while closing producer", e);

Original file line number	Diff line number	Diff line change
`@@ -189,6 +189,7 @@ public void start() {`
`189`	`189`	`public void stop() {`
`190`	`190`	`try {`
`191`	`191`	`destroy();`
	`192`	`+ this.running = false;`
`192`	`193`	`}`
`193`	`194`	`catch (Exception e) {`
`194`	`195`	`logger.error("Exception while closing producer", e);`