Questions tagged [masstransit]
MassTransit is a free, open source, lightweight service bus for the Microsoft .NET framework.
1,920
questions
0
votes
0
answers
12
views
MassTransit consumer not consuming message from Azure service bus
I have written a MassTransit consumer to consume a message from Azure Service Bus queue.
The consumer currently failing to consumer message from queue. I have set a breakpoint within Consumer.cs on ...
0
votes
1
answer
19
views
How to set MassTransit rate limit dynamically?
How can use the IPipeRouter to dynamically set the rate limit
Currently, I use UseRateLimit configuration method as following. But I need to change the rate limit dynamically.
cfg....
0
votes
0
answers
34
views
Object-oriented method of injecting headers into outgoing messages
I'd like to add headers to every outgoing message I send. These headers will contain information about the AWS environment from which the messages originate. In this case, I want to add headers with ...
0
votes
1
answer
23
views
How do I log exceptions from a Routing Slip Activity within MassTransit?
We've got a Routing slip activity which is throwing an exception, however, nothing is written to the logs when this errors.
I know we can listen to the RoutingSlipFaulted message and inspect the ...
-1
votes
1
answer
21
views
Unit Tests using MassTransit Test Harness randomly fail on build server
I wrote some test with the following structure using the TestHarness:
using MassTransit.Testing;
namespace g2fp.PosApi.UnitTests;
public class SampleTest : IAsyncLifetime
{
public async Task ...
0
votes
1
answer
23
views
Transactional outbox and inbox with optimistic concurrency control
is it possible to configure MassTransit transactional outbox and inbox with optimistic concurrency control instead of locks? In my database I have transactions with optimistic concurrency control and ...
0
votes
0
answers
19
views
Managing Data in Microservices and MassTransit
I'm breaking a big monolith application into microservices, the business domain revolves around users and features, I have a few features in the application (cab booking, bill payments, home cleaning, ...
0
votes
1
answer
39
views
'An existing connection was forcibly closed by the remote host' with Mass Transit and RabbitMQ
I have a fresh installation of RabbitMq and everything was working fine sending messages with Mass Transit and RabbitMQ. Suddently, this happened when I try to send a message ...
RabbitMQ.Client....
0
votes
1
answer
16
views
Trigger scheduled events in MassTransit 8 Saga
When upgrading from Masstransit 7.3 to Masstransit 8.0.15, I found what seems like a breaking change and I would like to know if anyone else had this issue before.
I have a Saga that schedules a job ...
0
votes
0
answers
22
views
Mechanism for managing faulty consumer in asynchronous messasing in microservices / modular monolith [closed]
I have modular monolith / microservices. One microservice has raised an event that something has happened. 3 other microservices are consumers. 2 of them have succesfully processed the request & ...
0
votes
1
answer
14
views
MassTransit publish to AWS topics from different accounts
I'm evaluating implementing MassTransit in replacement of native AWS SDK but I'm wondering if it supports configuring cross-account Topics.
This is what I'm trying to achieve:
Topic TopicA exists in ...
0
votes
1
answer
23
views
MassTransit get stuck creating topic for routing slip with Azure Service Bus
We've written some routing slips within MassTransit and currently, it's all using in-memory broker so that we can test it all which is perfectly fine. However, when we move it to using Azure Service ...
0
votes
1
answer
35
views
Mass Transit Integration Test: TestHarness Not Consuming Message
I have setup a MassTransit integration test, but I am not able to get it to work. I am using the Web Application Factory to setup the integration test. I want to consume a message, then create a ...
0
votes
1
answer
28
views
Can MassTransit consumers be triggered by the message contract class name
We are wanting to use MassTransit with Azure Service Bus across different Azure web apps. To keep with an existing pattern, we want to define consumers and the messages they respond to by the message ...
0
votes
1
answer
14
views
MassTransit how to unit test CompositeEvent in state machine
I'm having trouble testing a StateMachine that has a CompositeEvent.
All messages are being consumed by the saga. Furthermore, the FilesState has a value of 3, meaning that the CompositeEvent has been ...
0
votes
1
answer
18
views
How to log messages when kill switch activated and deactivated
I am using kill switch for the first time.
below is the code for kill switch in my application.
cfg.UseKillSwitch(options => options
.SetActivationThreshold(10)
.SetTripThreshold(0.15)
....
0
votes
1
answer
20
views
RabbitMQ MassTransit batching competing consumers
I've set up a batch consumer of an event ExampleEvent and set it to have ConcurrencyLimit = 16, MessageLimit = 100, TimeLimit = 5 sec and grouping by ExampleEvent.GroupingKey field.
This works fine ...
0
votes
0
answers
26
views
How can I subscribe to the Azure Service Bus deadletter queue in MassTransit?
I'm new to MassTransit and Azure Service Bus.
When a received message fails due to an unexpected exception, or maybe an unlucky power failure, I would like the message to go to the deadletter queue (...
0
votes
1
answer
45
views
.NET - How correctly set Azure Service Bus queue/topics for function
I am creating a project in .NET and I have one api application and next to it 2 functions. I want to communicate between the application and the functions using the Service bus for this I am using ...
0
votes
1
answer
85
views
Azure Function ServiceBusReceivedMessage not working
I am trying to create an azure function together with MassTransit and I have a problem with the ServiceBusReceivedMessage object that is a parameter in the function. It is according to the tutorial. ...
0
votes
1
answer
24
views
MassTransit how to unit test state machine
I'm having trouble configuring some unit tests for a StateMachine.
I have gone through most of the examples in GitHub as well as in Youtube but I can't figure out why this is not working.
The test ...
0
votes
1
answer
21
views
Masstransit: Unable to consume messages from the Azure Service Bus
recently I discovered the Masstransit package and decided to give it a try, but I'm a bit stuck.
I'm trying to subscribe to a predefined ASB topic using a predefined subscription.
I have a topic with ...
-2
votes
0
answers
53
views
Connecting to ActiveMQ server using SSL certificate
I am using MassTransit to connect to an ActiveMQ server. How can I pass the SSL certificate to the connection?
services.AddMassTransit(x =>
{
AddConsumers(activeMqConfig?.Consumers, assembly,...
0
votes
0
answers
17
views
How to define contract between services in rabbitmq? [duplicate]
How to define and type in advance a contract between two services that are located in different solutions? For example, there is a publisher and a subscriber that are on different clusters. The ...
0
votes
1
answer
23
views
MassTransit How to implement a sniffer
Related to my previous question, I have the same messages hierarchy and I would like implement one consumer which can handle all the different messages, to implement a kind of sniffer.
I've though in ...
0
votes
1
answer
22
views
MassTransit How to avoid creating an unneeded exchange
I use Net 6 API application which publishes and consumes messages via MassTransit using RabbitMQ as transport. I would like define a messages hierarchy with a common ancestor to all messages to ...
0
votes
1
answer
36
views
Communication between microservices using MassTransit and Rabbitmq
In .Net I had a solution with 2 microservice (API) and one shared layer (Shared Models). I wanted to send some data from one microservice to another using MassTransit and RabbitMQ. After implementing ...
1
vote
1
answer
55
views
Mass Transit: multiple subscribers to one consumer
we have Payment microservice which has a consumer called CollectPayment
and there is a feature service called Groceries Service that send a command called CollectPaymentCommand
this command is fetched ...
0
votes
1
answer
97
views
.NET - MassTransit with Azure function not recieve every time
Hi I have a question about using a topic in Azure Service Bus, which I control/configure using mass transit in my .NET application. My query is as follows, I use MassTransit to create a topic in my ...
0
votes
1
answer
41
views
MassTransit request/response - The host was not found for the specified address
I'm trying to implement an integration test scenario where Component A inside an IIS host requests some data from Component B (external component) over the RabbitMQ/Masstransit bus using the ...
0
votes
1
answer
33
views
MassTransit StateMachine not initiated
I'm trying to configure a MassTransit StateMachine saga that should be triggered when a message is sent, but sending the message does not initiate the saga; the message remains in the queue. If I ...
0
votes
1
answer
23
views
MassTransit IEndpointRegistrationConfigurator dynamic names
Good morning,
I have multiple (Micro-services) REST APIs that use MassTransit to either connect to RabbitMQ or Azure Service Bus depending on the environment.
When the applications starts they ...
2
votes
1
answer
36
views
.NET how to use MassTransit saga with seperated layers
I'm using mass transit to send messages. I have a project called SharedContracts that contains only dumb messages that are used by other projects. Then I have a Messaging project with consumers, as ...
0
votes
0
answers
62
views
MassTransit - Azure Functions / RabbitMQ - how to call into the consumer - and serialization question
I am trying MassTransit (8.0.15) and RabbitMQ (3.11.7) within an Azure Function (v4) App for local development on my box.
I am 'publishing' a message from a console app ... and I am able to hit the ...
-1
votes
1
answer
50
views
.NET Azure functions auto create subscriber
in my application, I use mass transit, which takes care of creating topics, subscriptions, and queues. Now, I have an Azure function, and I would like to use "objects" instead of directly ...
0
votes
1
answer
23
views
Error handling after publishing events masstransit
When using MassTransit, I was wondering how to handle exceptions after publishing an event. (not for consumers)
As you can see in code below, an exception occurs AFTER publishing an event, but before ...
0
votes
1
answer
28
views
Does mass transit azure function support saga state machine orchestration?
I am using AddMassTransitForAzureFunctions for azure function sb trigger . can I add mass transit Saga orchestration/state machine to the azure function app? is that compatible ? Any sample GitHub app ...
0
votes
0
answers
23
views
MassTransit with GraphAPI Consumer and Throttling
I'm working with MassTransit and RabbitMQ and one of the consumer will make a batch request to the Graph API. Given that a batch may contain throttled responses, I was wondering how to properly set up ...
0
votes
1
answer
54
views
MassTransit: Setting the default queue type to quorum queues with RabbitMQ
We are in the process of updating from using classic mirrored queues to using quorum queues. We are using MassTransit 6.0.0 and I have updated all our calls to ReceiveEndpoint to set the x-queue-type ...
0
votes
0
answers
20
views
How to test that a message was ignored by a MassTransit state machine?
I'm developing an application in C# using MassTransit's saga state machine feature, and I'm trying to write unit tests (NUnit) for my saga to assert that certain events are ignored in certain states.
...
0
votes
0
answers
29
views
mass transit consumer not receiving message from azure service bus queue
below is how I have configured mass transit to use azure service bus queue in program.cs
builder.Services.AddMassTransit(x =>
{
EndpointConvention.Map<IndexMessage>(new Uri($"queue:{...
0
votes
0
answers
22
views
Is It possible to use single mass transit rabbit mq consumer for multiple kafka cluster
In the current set up single kafka cluster and single mass transit rabbit mq consumer is used.
But in the new requirement two kafka clusters being created on different nodes .
Please note there will ...
0
votes
0
answers
20
views
MassTransit not working with existing RabbitMQ exchange and queue
Below is how I have configured Mass Transit in the program.cs of the producer
builder.Services.AddMassTransit(x =>
{
EndpointConvention.Map<IndexMessage>(new Uri($"queue:...
0
votes
1
answer
36
views
Setting message-ttl on queue level in MassTransit
My goal is to set expiration time for every message deliver to specified queue eg. queue consumer is down so message is not consumed for more that 10 seconds so I want to automatically delete this ...
0
votes
1
answer
23
views
MassTransit Xml Deserialization with xml containing attributes
Earlier I asked a Question on how to Deserialize an xml message (send wit ActiveMq).
I missed the fact that you can use UseRawXmlSerializer()if MassTransit.NewtonSoft was included.
Now I could ...
0
votes
2
answers
37
views
register Publish Filter for IMessageScheduler
I wrote a publish filter that has worked correct when I publish a message by IPublishEndpoint.now I need to have this filter when I publish a message by IMessageScheduler.
the following code is called ...
0
votes
1
answer
36
views
MassTransit + Kafka - Fault consumer not being called
I'm using MassTransit 8.0.10 along with Kafka as a rider, and what I'm trying to accomplish is to handle messages that couldn't be processed by an error condition, and do something with them (like ...
0
votes
1
answer
48
views
Multiple queues to publish in MassTransit and RabbitMQ in C#
I'm trying to coding a system where we have a queue to process messages. The problem is that I want to have two queues: one for develop environment and another for production environment.
Program.cs
...
0
votes
1
answer
37
views
MassTransit receive a message in Raw or XML format
I am trying to get an XML message from a queue (hosted by ActiveMQ). It works perfectly as long as I use JSON messages, but I do not get it to work with raw text or XML messages.
I have tried to ...
0
votes
1
answer
35
views
Published messages going into skipped while using RabbitMQ with Masstransit
I have 2 applications, one for publishing and another for subscribing.
Let's see the publishing code used for registering masstransit.
context.Services.AddMassTransit<IEmployeeSvcBus>(x =>
...