fix: made the worker terminate gracefully.

apache · Dec 16, 2021 · 6154562 · 6154562
1 parent e1c73a7
commit 6154562
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/plc4go/internal/plc4go/spi/default/DefaultCodec.go b/plc4go/internal/plc4go/spi/default/DefaultCodec.go
@@ -240,8 +240,12 @@ func (m *defaultCodec) Work(codec *DefaultCodecRequirements) {
 			// TODO: If this is an error, cast it to an error and log it with "Err(err)"
 			log.Error().Msgf("recovered from: %#v at %s", err, string(debug.Stack()))
 		}
-		workerLog.Warn().Msg("Keep running")
-		m.Work(codec)
+		if m.running {
+			workerLog.Warn().Msg("Keep running")
+			m.Work(codec)
+		} else {
+			workerLog.Info().Msg("Worker terminated")
+		}
 	}(workerLog)
 
 	// Start an endless loop