2,223 questions
-5
votes
1
answer
82
views
How to stop publishing Fault messages
In the MassTransit's ReceiveEndpoint method, I can set property
PublishFaults = false
to prevent publishing fault messages 'when no ResponseAddress or FaultAddress are present'. But is it possible ...
- 968
0
votes
0
answers
69
views
How to completely disable librdkafka native logs when using MassTransit Kafka transport (.NET)?
I am using MassTransit Kafka transport in a .NET application, and I cannot completely disable native librdkafka logs that are printed directly to stderr.
Example logs:
%3|1770535125.181|FAIL|rdkafka#...
- 43
0
votes
0
answers
38
views
Sending message to a different vhost doesn't work
Can I send a command message from a producer application that is connected to the default RabbitMQ vhost (/) to a consumer connected to a different vhost (/vhost-1) using MassTransit?
So far, this ...
- 55
2
votes
1
answer
99
views
How to implement SagaConsumeContext in MassTransit
I need to be able to listen to (event) messages that a Saga (SagaStateMachineInstance) handles. I already have a working solution for listening to messages handled by a regular MassTransit consumer ...
- 11
-1
votes
1
answer
113
views
Publish a message inside an IPublishObserver with MassTransit
I'm trying to publish a message inside an IPublishObserver.
The goal is to create trace data in a queue/stream. I could use a table but I prefer a queue/stream in this case.
using MassTransit.Kvint....
- 11
1
vote
0
answers
67
views
Using Mass Transit, is there a granular way to override the headers on error messages when there is a fault?
On errors in my service (while consuming a message) Mass Transit will attempt to send the message to an '_error' queue and will fail due to an SQS hard limit on message Attributes:
MassTransit....
- 23
0
votes
1
answer
53
views
How to auto create MassTransit error queues
We want to setup monitoring and alerts using Azure Monitor on our MassTransit Azure Service Bus _error queues. One problem we are having is that the _error queues are only created AFTER an error has ...
- 57
0
votes
1
answer
158
views
Using MassTransit IScopedClientFactory or IClientFactory inside singleton service
All my request clients are added, as this works (not only the generation of the client, but the client itself - the request is sent using rabbitmq and I get the response as expected):
using var scope =...
- 3,746
1
vote
1
answer
220
views
How can I completely and totally prevent retries using MassTransit and RabbitMQ?
I have a microservice using MassTransit to process messages off a RabbitMQ queue. However I am having a problem where upon an error, MassTransit retries processing the message and/or the message ...
user2015635
1
vote
1
answer
100
views
Microservices transactions with saga orchestrator
I'm trying to build microservices application. I want to make auth/register/login gateway service checks every request and modify headers to pass through to internal services and user profile service.
...
- 27
0
votes
0
answers
55
views
Masstransit not created _error queue for activity from routing slip
I need help with RoutingSlip in Masstransit, I have an action that can issue errors periodically, and I expected that in such a situation an error queue would be created and messages would appear ...
- 1
1
vote
0
answers
92
views
MassTransit throws errors in log
In my solution that contains a project which should handle long jobs with MassTransit MassTransit produces weird error logs.
When I start the project in my container, everything seems to work fine, ...
- 514
1
vote
1
answer
108
views
Why does adding UseEntityFrameworkOutbox break UseScheduledRedelivery?
MassTransit UseScheduledRedelivery stops working when UseEntityFrameworkOutbox is added
Problem
I have a MassTransit consumer that handles PostgreSQL concurrent update exceptions using ...
- 25
0
votes
1
answer
42
views
MassTransit consume direct queues per type with non-generics
TasksDispatcher pushes tasks into direct queues per JobType enum:
public async Task DispatchAsync(Job job, CancellationToken ct)
{
using var scope = this.scopeFactory.CreateScope();
var ...
- 2,976
0
votes
0
answers
57
views
MassTransit JobConsumer never hit
I have an ASP.NET Core solution that contains 2 services (each using MassTransit) and a common project that has the configuration part for both of the services.
The common project contains the ...
- 514