diff --git a/internal/processing/midi-message-decode.go b/internal/processing/midi-message-decode.go
index dc9523f..f594671 100644
--- a/internal/processing/midi-message-decode.go
+++ b/internal/processing/midi-message-decode.go
@@ -15,7 +15,7 @@ func (mmd *MIDIMessageDecode) Process(ctx context.Context, payload any) (any, er
 	payloadBytes, ok := payload.([]byte)
 
 	if !ok {
-		return nil, fmt.Errorf("mqtt.message.decode processor only accepts a []byte")
+		return nil, fmt.Errorf("midi.message.decode processor only accepts a []byte")
 	}
 
 	payloadMessage := midi.Message(payloadBytes)
diff --git a/internal/processing/midi-message-encode.go b/internal/processing/midi-message-encode.go
index 577e6d7..37118dc 100644
--- a/internal/processing/midi-message-encode.go
+++ b/internal/processing/midi-message-encode.go
@@ -15,7 +15,7 @@ func (mme *MIDIMessageEncode) Process(ctx context.Context, payload any) (any, er
 	payloadMessage, ok := payload.(midi.Message)
 
 	if !ok {
-		return nil, fmt.Errorf("mqtt.message.encode processor only accepts an mqtt.Message")
+		return nil, fmt.Errorf("midi.message.encode processor only accepts an midi.Message")
 	}
 
 	return payloadMessage.Bytes(), nil