服务总线触发azure webjob

Question

我已经创建了一个Azure webwork，它将向服务总线队列发送强类型消息，并成功发送。

我想创建另一个webjob，只要servicebus队列中有消息，就会触发该webjob。请在下面找到我正在尝试的代码。出于某种原因，尽管servicebus队列中有消息，但当我在本地运行webjob时，webjob未被触发并出现错误。

错误：

System.InvalidOperationException
{"Missing value for trigger parameter 'blobIinfo'."}

代码：

public static void Main()
{
    var config = new JobHostConfiguration
    {
        NameResolver = new QueueNameResolver(),
        ServiceBusConnectionString = ApplicationSettings.ServiceBusConnectionString
    };
    var host = new JobHost(config);
    host.Call(typeof(BankLineFileProcessorWebJob).GetMethod("ProcessQueueMessage"));
}


[NoAutomaticTrigger]
public static void ProcessQueueMessage(
    TextWriter log,
    [ServiceBusTrigger("testsftppollingqueue")] SftpQueueMessage blobIinfo
    )
{
    while (true)
    {
        log.WriteLine("Queue message refers to blob: " + blobIinfo.BlobUri);
        Thread.Sleep(TimeSpan.FromMinutes(PollingInterval));
    }
}

有谁能帮我解决这个问题吗？

谢谢

Answer 1

另外，请去掉NoAutomatic Trigger属性。

Answer 2

你得用

host.RunAndBlock();

而不是

host.Call(typeof(BankLineFileProcessorWebJob).GetMethod("ProcessQueueMessage"));