gistfile1.cs

public FieldBookServiceRunner()
{
    serviceBus = ObjectFactory.GetInstance<IServiceBus>();
    using (serviceBus)
    {
        SubscribeConsumers(ObjectFactory.Container, serviceBus);

        Console.ReadLine();
        _log.Info("Stopping Service Runner");
                
    }
}

private static void SubscribeConsumers(IContainer container, IServiceBus bus)
{
    var consumerInstances = container.Model.PluginTypes
                            .Where(p => typeof(Consumes<>.All).IsAssignableFrom(p.PluginType))
                            .SelectMany(p => p.Instances);

    consumerInstances.Each(type => bus.Subscribe(type.ConcreteType));
}