Disque.Net
Disque.Net copied to clipboard
Cannot access a closed Stream
how to fix this problem?
System.ObjectDisposedException: Cannot access a closed Stream.
at System.IO.__Error.StreamIsClosed()
at System.IO.BufferedStream.Write(Byte[] array, Int32 offset, Int32 count)
at CSRedis.Internal.RedisWriter.Write(RedisCommand command, Stream stream)
at CSRedis.Internal.RedisConnector.Call[T](RedisCommand1 command) at CSRedis.RedisClient.Write[T](RedisCommand1 command)
at Disque.Net.DisqueClient.AddJob(String queueName, String job, Int32 mstimeout)
at SGT.HOTW.DataInfo.AppLibs.DisqueUtility.AddJobToFds(Object data, String MemberFDS_Server)
using Common.Logging;
using Disque.Net;
using Newtonsoft.Json;
using StackExchange.Redis;
using System;
namespace TEST
{
public class DisqueUnity
{
private DisqueClient _disqueClient = new DisqueClient(new Uri($"disque://127.0.0.1:7711"));
public static DisqueUtility Instance { get; } = new DisqueUtility();
public void AddJobToFds(dynamic data, string Member)
{
try
{
var jsondata = JsonConvert.SerializeObject(data);
this._disqueClient.AddJob($"Group1", jsondata, 30000); //issue point
}
catch (Exception ex)
{
this.log.Error($"Exception:{ex}");
}
}
}
}