Клиент служебной шины Azure в модульном тесте с запуском по таймеру.

Я пытаюсь создать тест Xunit для функций, запускаемых таймером Azure, и мне нужно передать очередь клиента служебной шины в методе Run, и я не могу имитировать очередь служебной шины и не знаю, как передать в качестве параметра

Ниже моя лазурная функция

 [FunctionName("TimerJob")]
    public static async Task Run([TimerTrigger("%TimerJobExpression%")] TimerInfo myTimer,
        [ServiceBus("%Queue1%", Connection = "ServiceBusConnection")] IAsyncCollector<string> Queue1,
        [ServiceBus("%Queue2%", Connection = "ServiceBusConnection")] IAsyncCollector<string> Queue2,
        ILogger log)
    {
          //logic
    }

Ниже приведен метод тестирования, который я пытаюсь создать.

 [Fact]
public async Task Run_Queue()
    {
      
        var param1 = default(TimerInfo);
        var result = await ProducerClientTimerJob.Run(param1, null, null, logger);

       
    }