AutoMessageConsumerSubscriptionService.cs

	public class AutoMessageConsumerSubscriptionService : IRequiredService
	{
		private readonly IContainer _container;
		private readonly IServiceBus _serviceBus;
		private readonly ILogger _logger;

		public AutoMessageConsumerSubscriptionService(IContainer container, IServiceBus serviceBus, ILogger logger)
		{
			_container = container;
			_serviceBus = serviceBus;
			_logger = logger;
		}

		public void Start()
		{
			AutoSubscribeMessageConsumers(_container, _serviceBus, _logger);
		}

		public static void AutoSubscribeMessageConsumers(IContainer container, IServiceBus serviceBus, ILogger logger)
		{
			var consumerInstances = container.Model.InstancesOf(typeof(IMessageConsumer<>));

			logger.LogDebug("Found {0} message consumers.", consumerInstances.Count());

			foreach (var consumerInstance in consumerInstances)
			{
				logger.LogDebug("Subscribing message consumer {0}.", consumerInstance.Name);

				serviceBus.Subscribe(consumerInstance.ConcreteType);
			}
		}

		public void Stop()
		{
			_serviceBus.Dispose();
		}
	}