【发布时间】:2019-05-29 20:47:44
【问题描述】:
请看下面的代码,我摘自最新的快速入门教程:
//the messages
public class BasicRequest :
CorrelatedBy<Guid>
{
public Guid CorrelationId { get;set; }
public string Text { get; set; }
}
public class BasicResponse :
CorrelatedBy<Guid>
{
public Guid CorrelationId { get; set; }
public string Text { get; set; }
}
//the responder
public class Program
{
public static void Main()
{
Bus.Initialize(sbc =>
{
sbc.UseMsmq();
sbc.VerifyMsmqConfiguration();
sbc.UseMulticastSubscriptionClient();
sbc.ReceiveFrom("msmq://localhost/message_responder");
sbc.Subscribe(subs=>
{
subs.Handler<RequestMessage>(msg=> Bus.Instance.MessageContext<RequestMessage>().Respond(new BasiceResponse{Text = "RESP"+msg.Text}));
});
});
}
}
//the requester
public class Program
{
public static void Main()
{
Bus.Initialize(sbc =>
{
sbc.UseMsmq();
sbc.VerifyMsmqConfiguration();
sbc.UseMulticastSubscriptionClient();
sbc.ReceiveFrom("msmq://localhost/message_requestor");
});
Bus.Instance.PublishRequest(new RequestMessage(), x =>
{
x.Handle<ResponseMessage>(message => Console.WriteLine(message.Text));
x.SetTimeout(30.Seconds());
});
}
}
我从这里获取代码:https://automatonymous.readthedocs.io/en/latest/overview/request.html
我得到的错误是:
1) 总线不包含初始化定义
2) 找不到RequestMessage
很多其他网页引用了 Bus.Initialise:https://automatonymous.readthedocs.io/en/latest/overview/saga.html
【问题讨论】:
标签: c# masstransit