Shaker/Communication/ActiveMQ/EasyMQ.Common/IRPC.cs

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

namespace EasyMQ
{
    public interface IRPC
    {
        public void Respond<TRequest, TResponse>(Func<TRequest, IPrimitiveMap, TResponse> responder,string selector = "");
        public TResponse? Request<TRequest, TResponse>(TRequest request,ref bool istimeout,Dictionary<string,string>? properties = null, CancellationToken token = default, UInt32 timeout = 1000);
        public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Dictionary<string, string>? properties = null, CancellationToken token = default, UInt32 timeout = 1000);
    }
}