amqp: broker unit test fixed

surendratiwari3 · Feb 7, 2024 · 98197a0 · 98197a0
1 parent ff5183f
commit 98197a0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/broker/amqp/broker_test.go b/internal/broker/amqp/broker_test.go
@@ -38,7 +38,7 @@ func TestNewAMQPBroker(t *testing.T) {
 	mockAmqpProvider.On("CreateConnectionPool").Return(nil)
 	mockAmqpProvider.On("GetConnectionFromPool").Return(conn, nil)
 	mockAmqpProvider.On("ReleaseConnectionToPool", conn).Return(nil)
-	mockAmqpProvider.On("CreateAmqpChannel", conn).Return(channel, nil)
+	mockAmqpProvider.On("CreateAmqpChannel", conn, false).Return(channel, nil, nil)
 	mockAmqpProvider.On("DeclareExchange", channel, exchangeName, exchangeType).Return(nil)
 	mockAmqpProvider.On("DeclareQueue", channel, mock.Anything, mock.Anything).Return(nil)
 	mockAmqpProvider.On("QueueExchangeBind", mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(nil)