Shaker/Communication/ActiveMQ/EasyMQ/MQRPC.cs

using Apache.NMS;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace EasyMQ
{
    internal abstract class MQRPC :MQDispose, IRPC
    {

        public abstract TResponse? Request<TRequest, TResponse>(TRequest request, ref bool istimeout, Dictionary<string, string>? properties = null, CancellationToken token = default,UInt32 timeout = 1000);

        public abstract void Respond<TRequest, TResponse>(Func<TRequest, IPrimitiveMap, TResponse> responder,string selector = "");

        public abstract Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Dictionary<string, string>? properties = null, CancellationToken token = default, UInt32 timeout = 1000);

    }
}