Questions tagged [routing-slip]
19 questions
5
votes
1 answer
MassTransit - Wait for all activities to complete and then continue processing
If I have to much activities, does it cause blocking resources or request time out?
Here is my scenario:
I have an api controller which sends an Order request to consumer; I use Request/Response patern to recieve ErrorMessage property from consumer…
mkzpizza
- 81
- 1
- 5
3
votes
1 answer
How to monitor MassTransit Courier routing slip properly?
I managed to implement MassTransit Courier routing slip with bunch of activities. I decided to add a state machine to monitor it, so I created separate events and states and used EF Core as a storage for an Automatonymous state machine. To track the…
Isard
- 312
- 1
- 14
3
votes
1 answer
How do I execute a routing slip from a saga?
We are using a saga to model a workflow. This workflow waits for events to come in and perform some work based on the events. In some cases, we need to perform multiple tasks (chained .Then methods) one after the other but if one fails we want to…
sduplooy
- 14,340
- 9
- 41
- 60
2
votes
1 answer
How can I unit test a MassTransit consumer that builds and executes a routing slip?
In .NET Core 2.0 I have a fairly simple MassTransit routing slip that contains 2 activities. This is built and executed in a consumer and it all ties back to an automatonymous state machine. It all works great albeit with a few final clean tweaks…
Ben Thomson
- 1,083
- 13
- 29
1
vote
1 answer
MassTransit - Redeliver message in routing slip activity
I working on a project using masstransit Courier. I'm trying to redeliver a message for reexecuting an activity after 1 hour.
This is my code in the execute activity method:
await context.Redeliver(TimeSpan.FromMinutes(60));
var…
Alessandro Pescini
- 11
- 2
1
vote
1 answer
Is there a way to execute the compensation from faulted activity
Lets assume I have defined the routing slip activity. Within Execute method I would like to make several asynchronous service calls. Lets assume 3 service calls. Two of them succeed and one fails. Then I would like to execute compensate action of…
tgrabus
- 103
- 1
- 9
1
vote
1 answer
Camel RoutingSlip needs end() within Split
When using the splitter and routing slip to route pieces of the body to different endpoints, I discovered that an .end() is needed to avoid anything outside the split block from being included.
The desired behavior was to split the body, route each…
user10142760
- 23
- 5
1
vote
1 answer
Migrating from MT 2.9.5 to 4.0.1 and getting "The routingSlip must contain at least one activity log"
We've begun the journey of migrating from MassTransit 2.9.5 (with Courier addon) to MassTransit 4.0.1. Things are going slow, but OK and I am excited about the new (to us) functionality... but I've hit a wall with Courier.
Here's a braindead simple…
Tyler Austen
- 120
- 9
0
votes
1 answer
send data to RoutingSlipCompleted consume method from activity
I have some data in activity which I want to get it in RoutingSlipCompleted consume method. I know we can send data with CompletedWithVariables from a activity to b activity. But I was wondering how it is possible to get data from activity in…
Ali Eshghi
- 1,131
- 1
- 13
- 30
0
votes
1 answer
'RoutingSlipCompleted' does not contain a definition for 'GetVariable'
after using massTransit (8.0.8) I got following error :
'RoutingSlipCompleted' does not contain a definition for 'GetVariable'
and the best extension method overload
'RoutingSlipEventExtensions.GetVariable(ConsumeContext,
string, Guid)' requires a…
Ali Eshghi
- 1,131
- 1
- 13
- 30
0
votes
1 answer
How to split value generating new extra row but leaving blank only one value from the new row in pandas
I have a dataframe that looks like this:
ID Number Description Code Total Cost Store ID
A33 Ice cream; Chocolate 20 5
B44 Chips; Milk 15 6
C66 Cheese;…
nrod88
- 25
- 5
0
votes
1 answer
Use message retry for courier
As you know, in Masstransit, we can set up a UseMessageRetry. This method can help us to retry the message sending process once more.
This process continues as long as we hit errors.
The problem that I have encountered is that this setting is a…
Mohammad Bigdeli
- 108
- 10
0
votes
0 answers
MassTransit message encryption and routing slip events
I have enabled encryption for my RabbitMQ bus as per MassTransit documentation:
bus = Bus.Factory.CreateUsingRabbitMq(rabbit =>
{
rabbit.Durable = true;
rabbit.Host(new Uri(settings.ServerUri), h =>
{
…
IvanD
- 1
0
votes
1 answer
MassTransit - Prioritize RabbitMQ Message on Routing Slip
RabbitMQ supports message priority: https://www.rabbitmq.com/priority.html
MassTransit allows user to set this up when configuring endpoints and when sending/publishing a message.
Question: Would it be possible to set a message priority when using a…
igorguerra
- 53
- 4
0
votes
1 answer
Why Compensate method doesn't Call when a consumer thrown exception in MassTransit RouterSlip
I've built a router slip inside a saga state machine :
var builder = new RoutingSlipBuilder(NewId.NextGuid());
var submitOrderUrl = QueueNames.GetActivityUri(nameof(SubmitOrderActivity));
builder.AddActivity("SubmitOrder",…
Mortaza Ghahremani
- 362
- 2
- 8