fix(plc4go/cbus): disconnect message codec on connection error

apache · Mar 21, 2023 · e4e92b0 · e4e92b0
1 parent 7701247
commit e4e92b0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/plc4go/internal/cbus/Connection.go b/plc4go/internal/cbus/Connection.go
@@ -455,6 +455,9 @@ func (c *Connection) fireConnectionError(err error, ch chan<- plc4go.PlcConnecti
 	} else {
 		log.Error().Err(err).Msg("awaitSetupComplete set to false and we got a error during connect")
 	}
+	if err := c.messageCodec.Disconnect(); err != nil {
+		log.Debug().Err(err).Msg("Error disconnecting message codec on connection error")
+	}
 }
 
 func (c *Connection) fireConnected(ch chan<- plc4go.PlcConnectionConnectResult) {