Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public async Task HandleAsync(IConsumingContext ctx, IMessage<InvariantsEstimatedRequest> message)
- {
- var request = message.Payload;
- var response = await invariantsEstimatedRequestHandler.Handle(request);
- bus.Publish(publishingKey, response, new BasicProperties { CorrelationId = message.CorrelationId ?? string.Empty });
- await ctx.Accept();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement