IMessageQueue.cs 249 B

123456789101112
  1. using NATS.Client;
  2. using Worker.Messaging.Messages;
  3. namespace Worker.Messaging
  4. {
  5. public interface IMessageQueue
  6. {
  7. IConnection CreateConnection();
  8. void Publish<TMessage>(TMessage message) where TMessage : Message;
  9. }
  10. }