GH-777: Reset running on stop()

garyrussell · garyrussell · commit e7a12066dc12 · 2018-08-21T15:31:23.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
@@ -176,6 +176,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
`@@ -176,6 +176,7 @@ public void start() {`
`176`	`176`	`public void stop() {`
`177`	`177`	`try {`
`178`	`178`	`destroy();`
	`179`	`+ this.running = false;`
`179`	`180`	`}`
`180`	`181`	`catch (Exception e) {`
`181`	`182`	`logger.error("Exception while closing producer", e);`