Example message consumer factory

example-consumer-factory.cs

public class ExampleConsumerFactory : ConsumerFactoryBase {

  public override IEnumerable<IMessageConsumer> GetConsumers(IMessageContext messageContext) {

    var consumers = new List<IMessageConsumer>();

    if(messageContext.Message.Headers.Exists("queues")) {

      var queues = messageContext
                      .Message
                      .Headers
                      .GetValue("queues")
                      .Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);

      foreach(var queue in queues) {

        var path = String.Format(".\private$\{0}", queue);
        var consumer = new MsmqMessageConsumer();

        consumer.Configure(new Dictionary<string, string> { { "queue-path", path } });

        consumers.Add(consumer);
      }
    }

    return consumers;
  }

}