MassTransit Bug

gistfile1.cs

	public interface ICommandPublisher
	{
		void Publish<T>(T command) where T : ICommand;
	}

	public class MassTransitCommandPublisher : ICommandPublisher, ILoggingSource
	{
		public void Publish<T>(T command) where T : ICommand
		{
			this.Debug("Publishing command {0}", command.GetType().Name);
			Bus.Instance.Publish(command);
		}
	}

class Program
{
	static void Main(string[] args)
	{
            Bus.Initialize(sbc =>
			{
				sbc.UseMsmq();
				sbc.VerifyMsmqConfiguration();
				sbc.UseMulticastSubscriptionClient();
				sbc.ReceiveFrom(queueAddress);
				sbc.SetPurgeOnStartup(true);
				sbc.Subscribe(
					s =>
						{
							s.Handler<DiagnosticCommand>(msg => this.Info(msg.Text));
						});
			});

			Console.Clear();
			Bus.Instance.Publish(new DiagnosticCommand {Text = "WORKS!  publish DiagnosticCommand directly to Bus.Instance"});

			var publisher = new MassTransitCommandPublisher();
			publisher.Publish(new DiagnosticCommand() {Text = "NOPE!  publish DiagnosticCommand to bus via ICommandPublisher"});
			this.Debug("Published command through publisher");
}
}