Adds link between an exchange and queue in RabbitMQ

Parameters

• alias (string, optional): Optional parameter with the name of the Stream Alias as defined in the Stream Adapter configuration. The default value is “Stream1”.

• exchangeName (string): Name of the exchange to which the queue will be linked.

• exchangeType (ExchangeType): Type of the exchange. It can be:

  • Direct: Routes messages to queues with an exact routing key.
  • Fanout: Routes messages to all queues connected to the exchange.
  • Topic: Routes messages to queues based on routing key patterns.
  • Headers: Routes messages based on message headers.

• queueName (string): Name of the queue that will be linked to the exchange.

• routingKey (string): Routing key used to direct messages from the exchange to the queue.

• arguments (IDictionary<string, object>, optional): Additional arguments for the connection, such as specific filters or configuration parameters.

Return

• bool: Returns true if the link between the exchange and the queue is successfully created; otherwise, returns false.

Here’s an example of how to use the AddBindingExchangeQueueRabbitMQ method in your application:

1. Performing an Exchange Direct Bind without using an argument

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

var exchangeName = "myExchangeName";
var queueName= "myQueueName";
var routingKey = "myQueueName";
bool success = Dp.Stream.AddBindingExchangeQueueRabbitMQ(exchangeName,
ExchangeType.Direct, queueName, routingKey, null);
    if (success)
    {
        Console.WriteLine("Bind realizado com successo.");
    }
    else
    {
        Console.WriteLine("Falha ao criar Bind.");
    }

2. Binding Exchange Fanout

1
2
3
4
5

var exchangeName = "myExchangeName";
var queueName = "myQueueName";
var routingKey = ""; // Not using in fanout
bool success = Dp.Stream.AddBindingExchangeQueueRabbitMQ(exchangeName,
ExchangeType.Fanout, queueName, routingKey, null);

3. Binding an Exchange Topic

1
2
3
4
5

var exchangeName = "myExchangeName";
var queueName = "myQueueName";
var routingKey = "topic.routing.key"; // Important parameter in Exchange Topic
bool success = Dp.Stream.AddBindingExchangeQueueRabbitMQ(exchangeName,
ExchangeType.Topic, queueName, routingKey, null);

4. Binding Exchange Headers Using Arguments

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

var exchangeName = "myExchangeName";
var queueName = "myQueueName";
var routingKey = string.Empty; // Not using in Headers
var arguments = new Dictionary<string, object>
    {
        { "headerKey1", "headerValue1" },
        { "headerKey2", "headerValue2" }
    };
bool success = Dp.Stream.AddBindingExchangeQueueRabbitMQ(exchangeName,
ExchangeType.Headers, queueName, routingKey, arguments);

Considerations

• Make sure that exchangeName and queueName are correctly configured and exist in RabbitMQ.
• Adjust the routingKey and arguments as needed for your message routing strategy.
• Native implementations of RabbitMQ are specific to this platform and cater to particular use cases. If you migrate to another streaming platform, you’ll need to adjust your code to use Devprime’s standard methods or the new platform’s specific methods.