Files

17 lines
408 B
C#

using System;
using System.Threading.Tasks;
namespace FinlyticTechnicals.Services;
public interface ITAMqttRpcClient
{
Task<TResponse?> SendRpcRequestAsync<TResponse, TRequest>(
string channel,
TRequest requestData,
TimeSpan? timeout = null)
where TResponse : class
where TRequest : class;
Task PublishAsync<T>(string topic, T data, bool retain = false);
}