目前我正在使用Microsoft.Azure.ServiceBus.IQueueClient
来RegisterMessageHandler
,然后我接收到的消息类型是Microsoft.Azure.ServiceBus.Message
。
根据文档:
延迟消息API。.NET Framework客户端中的API是BrokeredMessage.Defer或BrokeredMessage.DeferAsync,.NET Standard客户端中的API是MessageReceiver.DeferAsync,并且Java客户端中为IMessageReceiver.defer或IMessageReceiver.deferAsync。
... 但是似乎没有库与我实际使用的类相关。如何延迟?我需要使用哪些类和其他内容才能延迟消息?上面的所有示例都没有足够的代码片段来解释它。
根据@Gaurav的要求更新
从您的答案中,我可以看到我的消息具有该属性:
message.ScheduledEnqueueTimeUtc = DateTime.UtcNow.AddHours(1);
但是queueClient
也有这个方法:
queueClient.ScheduleMessageAsync(message, DateTime.UtcNow.AddHours(1));
因为我看不到如何在不调用 queueClient
的情况下表达我已经设置了ScheduledEnqueueTimeUtc
,所以我将尝试使用 'scheduledMessageAsync
'。