这是我的 MassTransit 代码。
订阅者控制台应用程序:
namespace ConsoleSubscriber
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("set up a subscriber");
Bus.Initialize(config =>
{
config.UseMsmq();
config.VerifyMsmqConfiguration();
config.UseMulticastSubscriptionClient();
config.UseControlBus();
config.ReceiveFrom("msmq://localhost/test_end");
config.Subscribe(s => s.Instance(new Consumer()).Permanent());
});
Console.Read();
}
}
public class Consumer : Consumes<Message>.All
{
public void Consume(Message message)
{
Console.WriteLine("start consuming message");
if (string.IsNullOrEmpty(message.Ids))
{
Console.WriteLine("no ids");
}
else
{
Console.WriteLine("ids are " + message.Ids);
}
}
}
}
留言类:
[Serializable]
public class Message
{
public string Ids { get; set; }
}
发布者控制台应用程序:
namespace ConsolePublisher
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("start publishing");
// initialize bus
Bus.Initialize(config =>
{
config.UseMsmq();
config.VerifyMsmqConfiguration();
config.UseMulticastSubscriptionClient();
config.UseControlBus();
config.ReceiveFrom("msmq://localhost/test_queue");
});
Bus.Instance.Publish(new Message());
Console.WriteLine("Message sent 1");
var msg2 = new Message() { Ids ="1,2,3,4" };
Bus.Instance.Publish(msg2);
Console.WriteLine("Message sent 2");
Console.Read();
}
}
}
当我运行这两个控制台应用程序时,消费者似乎没有接收到消息。有任何想法吗?
干杯!