我有一个netstandard2.1
应用程序,我正在使用 nuget package "Microsoft.Azure.ServiceBus" Version="4.1.1"
。
我正在创建一个 azure 服务总线SubscriptionClient
并尝试使用PeekBatch
and ReceiveBatch
,但我遇到了错误,这里缺少什么?
“SubscriptionClient”不包含“PeekBatch”的定义,并且找不到接受“SubscriptionClient”类型的第一个参数的可访问扩展方法“PeekBatch”
“SubscriptionClient”不包含“ReceiveBatch”的定义,并且找不到接受“SubscriptionClient”类型的第一个参数的可访问扩展方法“PeekBatch”
_subscriptionClient = new SubscriptionClient(connectionString, topicName, subscriptionName, ReceiveMode.ReceiveAndDelete);
_subscriptionClient.PrefetchCount = 16;
while (_subscriptionClient.PeekBatch(16).Any())
{
var pendingMessages = _subscriptionClient.ReceiveBatch(16, TimeSpan.FromSeconds(1))?.ToList();
if (pendingMessages != null)
{
foreach (var message in pendingMessages)
{
// do processing of the message
}
}
}