0
我需要将我们的服务总线nuget包升级到3.2.2(认为偶处理器主机需要它),但我总是将我们的服务总线项目lib保留在2.8.2。这主要是由于BeginReceive()和EndReceive()看起来已被删除。是否有任何理由或反正我可以很容易地转换这个Azure服务总线3.2.2 BeginReceive()
public void StartReceiving(RecieverCallback callback, TimeSpan waittime, object state = null)
{
this._recieverCallback = callback;
_queueClient = this.MessagingFactory.CreateQueueClient(QueueName, ReceiveMode);
// make initial async call
_asyncresult = _queueClient.BeginReceive(waittime, ReceiveDone, _queueClient);
}
public void ReceiveDone(IAsyncResult result)
{
if (result != null)
{
try
{
var tmpClient = result.AsyncState as QueueClient;
var brokeredMessage = tmpClient.EndReceive(result);
if (brokeredMessage != null)
{
if (ReceiveMode == ReceiveMode.PeekLock)
{
brokeredMessage.Complete();
}
var tmpMessage = brokeredMessage.GetBody<T>();
ProcessMessageProperties(tmpMessage, brokeredMessage);
_recieverCallback(tmpMessage);
}
}
catch (Exception ex)
{
_logger.Fatal("ReceiveDone: {0}", ex.Message);
Console.WriteLine(ex.Message);
}
}
// do recieve for next message
_asyncresult = _queueClient.BeginReceive(ReceiveDone, _queueClient);
}
下图显示了,如果我升级servicebus 3.2.2,我相信这将解决原来的错误会发生什么(程序运行3.2.2,LIB项目运行2.8.x)