using Cloud.Services.Broker.Support;

namespace Cloud.Services.Broker
{
    public interface IBrokerService 
    {
        Task<CommandResult> Produce(Command command);
        Task<T> Consume<T>(string topic);
    }
}