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是静态的,并且有多个线程在使用和处理它。让它不是静态的解决了我的问题。
这篇关于服务总线置放对象的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
沃梦达教程
本文标题为:服务总线置放对象
猜你喜欢
- C#MongoDB使用Builders查找派生对象 2022-09-04
- Web Api 中的 Swagger .netcore 3.1,使用 swagger UI 设置日期时间格式 2022-01-01
- 如何用自己压缩一个 IEnumerable 2022-01-01
- 带有服务/守护程序应用程序的 Microsoft Graph CSharp SDK 和 OneDrive for Business - 配额方面返回 null 2022-01-01
- C# 中多线程网络服务器的模式 2022-01-01
- WebMatrix WebSecurity PasswordSalt 2022-01-01
- 输入按键事件处理程序 2022-01-01
- 在哪里可以找到使用中的C#/XML文档注释的好例子? 2022-01-01
- MoreLinq maxBy vs LINQ max + where 2022-01-01
- 良好实践:如何重用 .csproj 和 .sln 文件来为 CI 创建 2022-01-01