![]() ![]() ![]() Well I've tried this above, and when CancelJob is published, the CancellationToken related with the context that I want to cancel stays the same, in other words context.CancellationToken. Which will throw an exception that I should propagate further and transition the Saga to the final state? If I understood this right, when CancelJob is published, 'under the hood' it finds the context of the Job with the specified JobId (this needs to be same as the CorrelationId of the job that I want to cancel?) and it cancels the CancellationToken related with that contextĪnd in the consumer methods in order to check if the chain of events is canceled I need to haveĬ() Observability via Open Telemetry (OTEL) Fully-supported, widely-adopted, a complete end-to-end solution. Write once, then deploy using RabbitMQ, Azure Service Bus, and Amazon SQS. I have an API that exposes an endpoint which (when hit) publishes the initial message that kicks of chain of events in the state machine: await _publishEndpoint.Publish(new ) masstransit with rabbitmq: Why message auto moved to skipped queue when it responing Ask Question Asked 4 years, 11 months ago Modified 4 years, 7 months ago Viewed 2k times 0 UCITY.API request to UCITY. MassTransit provides a developer-focused, modern platform for creating distributed applications without complexity. Working with RabbitMQ exchanges and publishing messages from Ruby with Bunny About this guide This guide covers the use of exchanges according to the AMQP 0.9.1 specification, including broader topics related to message publishing, common usage scenarios and how to accomplish typical operations using Bunny. I have a question related to cancellation of the Saga state machine instance that uses RabbitMQ. In RabbitMQ, an exchange is a component that receives messages from producers and routes them to one or more queues based on a set of rules called bindings. ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |