Add default queue implementation

Gsantomaggio · Gsantomaggio · commit ef35cd5ec080 · 2026-02-13T11:36:00.000+01:00
Signed-off-by: Gabriele Santomaggio &lt;G.santomaggio@gmail.com&gt;
diff --git a/pkg/rabbitmqamqp/amqp_connection_recovery.go b/pkg/rabbitmqamqp/amqp_connection_recovery.go
@@ -127,7 +127,7 @@ func (q *queueRecoveryRecord) toIQueueSpecification() IQueueSpecification {
 			Arguments:    q.arguments,
 		}
 	}
-	return nil
+
 }
 
 type exchangeRecoveryRecord struct {

Original file line number	Diff line number	Diff line change
`@@ -127,7 +127,7 @@ func (q *queueRecoveryRecord) toIQueueSpecification() IQueueSpecification {`
`127`	`127`	`Arguments: q.arguments,`
`128`	`128`	`}`
`129`	`129`	`}`
`130`		`- return nil`
	`130`	`+`
`131`	`131`	`}`
`132`	`132`
`133`	`133`	`type exchangeRecoveryRecord struct {`