elsa-workflows / elsa-workflows/elsa-core

Elsa.Activities.RabbitMq - Can't use default exchange to dispatch message

Open
#4,636 0 comments 2 reactions 0 assignees View on GitHub
triaged
Dominant language
C#
Stars
7.9k
Forks
1.5k
Avg merge
15h 22m
Merged PRs (30d)
114

Description

Hi,

I'm using the RabbitMq activity to send messages to a queue through the default exchange provided by RabbitMq itself (AMQP Default).

To do this, I'm using an overload of the **'SendTopicMessage'** method that only informs the queue name, without the need to inform the exchange. However, this is not obeyed by the activity, as it is using the **'RebusTopics'** exchange.

Please let me know if there are any settings missing.

More info:

**Activity Version:** 2.13.0
**Method Overloading Used:**
```csharp
SendTopicMessage(this IBuilder builder, string connectionString, string topic, string message, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default)
```
**Activity Execution Log:**
```log
[20:26:08 DBG] Executing activity SendRabbitMqMessage activity-2 for workflow c0a3d0b4e6d54d1796f4a5e292824087
[INF] Rebus.Internals.ConnectionManager (.NET ThreadPool Worker): Initializing RabbitMQ connection manager for one-way transport
[INF] Rebus.Bus.RebusBus (.NET ThreadPool Worker): Bus "Rebus 6" started
[DBG] Rebus.Pipeline.Send.SendOutgoingMessageStep (.NET ThreadPool Worker): Sending "{"Context":2,"WorkerId":2}" -> "schedule-worker-dev@RebusTopics"
[20:26:08 DBG] Executed activity SendRabbitMqMessage activity-2 for workflow c0a3d0b4e6d54d1796f4a5e292824087
```
> NOTE: In the penultimate line we see the definition of the RebusTopics exchange.

**RebusTopics Exchange Rates:**

![image](https://github.com/elsa-workflows/elsa-core/assets/42707066/a7e79e6f-e032-4c4a-849e-454d2b786cd3)

Tks!

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.