Disque.Net icon indicating copy to clipboard operation
Disque.Net copied to clipboard

Cannot access a closed Stream

Open markchan1209 opened this issue 5 years ago • 0 comments

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}");
			}
			
		}
	}
}

markchan1209 avatar Aug 09 '20 14:08 markchan1209