Typos

rabbitmq · Sep 27, 2024 · 3221fe7 · 3221fe7
1 parent 7dcb1b6
commit 3221fe7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/common/common.go b/pkg/common/common.go
@@ -54,13 +54,13 @@ func NewConsumer(protocol config.Protocol, cfg config.Config, id int) (Consumer,
 	case config.STOMP:
 		c := stomp_client.NewConsumer(cfg, id)
 		if c == nil {
-			return nil, fmt.Errorf("failed to create an AMQP-1.0 consumer")
+			return nil, fmt.Errorf("failed to create a STOMP consumer")
 		}
 		return c, nil
 	case config.MQTT:
 		c := mqtt_client.NewConsumer(cfg, id)
 		if c == nil {
-			return nil, fmt.Errorf("failed to create an AMQP-1.0 consumer")
+			return nil, fmt.Errorf("failed to create an MQTT consumer")
 		}
 		return c, nil
 	}