服务总线置放对象

Service Bus Disposed Object(服务总线置放对象)

本文介绍了服务总线置放对象的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我通过服务总线在Azure上使用消息队列体系结构。偶尔,当我尝试向队列发送消息时,它会失败。以下是我收到的错误:

有时我收到此消息

Message:Can't create session when the connection is closing. 

其他时候我收到此消息

Message:Cannot access a disposed object.
Object name: 'FaultTolerantAmqpObject`1'. 

记住,这并不是经常发生的。有时,我会为服务总线创建数千条消息。我正在为发送到队列的每封邮件调度一个异步任务

以下是我的代码

Task.Run(() => new ServiceBusService().SendQueueMessage(busMessageObject));

ServiceBus类

public class ServiceBusService
{ 
static string ServiceBusConnectionString = AzureUtils.SERVICE_BUS_CONNECTIONSTRING;
const string QueueName = "eventqueue";
static IQueueClient queueClient;

   public async Task SendQueueMessage(JObject jObject, DateTime? scheduledEnqueueTimeUtc = null)
        {
            string jsonObject = "";
            string scheduledTime = "";

            if(scheduledEnqueueTimeUtc.HasValue)
            {
                scheduledTime = scheduledEnqueueTimeUtc.Value.ToLongTimeString();
            }

            try
            {
                queueClient = new QueueClient(ServiceBusConnectionString, QueueName);
                var message = new Message(Encoding.UTF8.GetBytes(jObject.ToString()));

                if(scheduledEnqueueTimeUtc.HasValue)
                    message.ScheduledEnqueueTimeUtc = scheduledEnqueueTimeUtc.Value;

                await queueClient.SendAsync(message);
                await queueClient.CloseAsync();
            }
            catch (Exception e)
            {
                Trace.TraceError($"{Tag()} " + e.InnerException + " " + e.Message);
            }
        }
}

推荐答案

这是因为我的QueueClient是静态的,并且有多个线程在使用和处理它。让它不是静态的解决了我的问题。

这篇关于服务总线置放对象的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本文标题为:服务总线置放对象

基础教程推荐