Update pkg/rabbitmqamqp/amqp_utils.go

Gsantomaggio · Copilot · web-flow · commit 4598ad564915 · 2025-11-17T12:57:44.000+01:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/pkg/rabbitmqamqp/amqp_utils.go b/pkg/rabbitmqamqp/amqp_utils.go
@@ -120,7 +120,7 @@ func decodePathSegments(segment string) (string, error) {
 	return decoded, nil
 }
 
-// remove /queue/ prefix from the queue address
+// remove /queues/ prefix from the queue address
 func trimQueueAddress(address string) (string, error) {
 	prefix := "/queues/"
 	if len(address) < len(prefix) || address[:len(prefix)] != prefix {

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ func decodePathSegments(segment string) (string, error) {`
`120`	`120`	`return decoded, nil`
`121`	`121`	`}`
`122`	`122`
`123`		`-// remove /queue/ prefix from the queue address`
	`123`	`+// remove /queues/ prefix from the queue address`
`124`	`124`	`func trimQueueAddress(address string) (string, error) {`
`125`	`125`	`prefix := "/queues/"`
`126`	`126`	`if len(address) < len(prefix) \|\| address[:len(prefix)] != prefix {`