Пожалуйста, посмотрите код ниже, который я взял из последних руководств по быстрому старту:
//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