На контроллере веб-API я хочу запустить Saga, которая будет вызывать другие веб-API с помощью шаблона запрос-ответ.
var sendToUri = new Uri($"{RabbitMqConstants.RabbitMqUri}{RabbitMqConstants.SagaQueue}");
var requestClient = new MessageRequestClient<ICustomerSearchReceivedEvent, ICustomerSearchCompletedEvent>(_bus, sendToUri, TimeSpan.FromSeconds(300));
Из саги в конце я хочу отправить ответ обратно :
During(CustomerSearchRequestAwaitValidationState,
When(CustomerSearchRequestValidationPassedEv)
.ThenAsync(async context =>
{
var endpoint = await context.GetSendEndpoint(context.Instance.ResponseAddress);
await endpoint.Send(new CustomerSearchCompletedEvent(context.Instance) /*, c=>c.RequestId = c.Message.RequestId */);
})
.Finalize());
, но установка RequestId не работает c => c .RequestId = c .Message.RequestId: (
Спасибо