elsa-workflows / elsa-workflows/elsa-core
Elsa.Activities.RabbitMq - Can't use default exchange to dispatch message
- 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:**

Tks!
Contributor guide
Assessment
This issue has not been assessed yet.