Generic Masstransit Message Publisher/Sender

MessagePublisher.cs

using Dovetail.Commons;
using MassTransit;

namespace Dovetail.Carrier.Core
{
	public interface IMessagePublisher
	{
		void Publish<MESSAGE>(MESSAGE message) where MESSAGE : class;
	}

	public class MessagePublisher : IMessagePublisher 
	{
		private readonly MessageBusSettings _messageBusSettings;
		private readonly IEndpointFactory _endpointFactory;

		public MessagePublisher(MessageBusSettings messageBusSettings, IEndpointFactory endpointFactory)
		{
			_messageBusSettings = messageBusSettings;
			_endpointFactory = endpointFactory;
		}

		public void Publish<MESSAGE>(MESSAGE message) where MESSAGE : class
		{
			var queueName = _messageBusSettings.MessageQueue;
			var messageEndpoint = _endpointFactory.GetEndpoint(queueName);
			messageEndpoint.Send(message);
		}
	}
}