Question

1 D-1, 1 D-1 页: 1 AutoCompleteMessages = 虚假。

不可能收到同一届会议的下一个信息,直至<代码>。本届会议的致辞请填满MessageAsync?

早就在电动手填满之后,如果我称之为<密码>,就会收到下一个信息。页: 1

These are the options for the ServiceBusSessionProcessor:

var processorSessionOptions = new ServiceBusSessionProcessorOptions()
{
    AutoCompleteMessages = false,
    MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(10),
    MaxConcurrentSessions = 5,
    MaxConcurrentCallsPerSession = 1
};

我只想收到会议的一份信息,而不是在<代码>之前收到下一个信息。页: 1

The result I m getting is that when the message handler finished, the next session message is being received.

Answer 1

感谢你的评论 @Sean Feldman 如果本届会议没有需要处理的任何信息,会议处理员将总是召集下一届会议。

是的,在把MessageAsync称作会议致词之前,不可能收到同一届会议的下一个信息:Bus 。

AFAIK, The serviceBusSessionProcessor 在第一个信息是之前,不提供阻止收到下一个信息的途径。然而,马克斯·科雷什每一选择可用来将每届会议同时呼吁的次数限制在一次。这确保每届会议只处理一个信息。因此,它将确保每次会议只处理一个电文。

不动产得到最多6.net而不是7.net的支持,详情见 SO 。

 string connectionString = "";
    string queueName = " ";

    var client = new ServiceBusClient(connectionString);
    ServiceBusProcessor processor = client.CreateProcessor(queueName, new ServiceBusProcessorOptions
    {
        MaxConcurrentCalls = 5,
        AutoCompleteMessages = false
    });

    processor.ProcessMessageAsync += ProcessMessageAsync;
    processor.ProcessErrorAsync += ProcessErrorAsync;

    await processor.StartProcessingAsync();

    Console.WriteLine("Press any key to stop receiving...");
    Console.ReadKey();

    await processor.StopProcessingAsync();
    await processor.CloseAsync();
}

private static async Task ProcessMessageAsync(ProcessMessageEventArgs args)
{
    var message = args.Message;

    // Your processing logic here

    // Simulate processing
    await Task.Delay(TimeSpan.FromSeconds(5));

    // Complete the message
    await args.CompleteMessageAsync(message);

    Console.WriteLine($"Message processed and completed.");
}

private static Task ProcessErrorAsync(ProcessErrorEventArgs args)
{
    Console.WriteLine($"Error processing message: {args.Exception.Message}");
    return Task.CompletedTask;
}

<<>Output>:

友情链接