The Devprime platform supports RabbitMQ’s standard exchange models through native methods that access the platform-specific features according to the desired exchange type (Direct, Fanout, Topic, Headers).
| Exchange Model | Summary |
|---|---|
| Direct | Routes messages to queues whose routing keys exactly match the key specified in the message. Ideal for scenarios where there is an exact match between the routing key and the queues. |
| Fanout | Distributes messages to all queues connected to the exchange, regardless of the routing key. Used in broadcast scenarios, where all connected queues must receive the message. |
| Topic | Routes messages to one or more queues based on routing key patterns. It allows the use of wildcards (* and #), and is useful in scenarios where there is a need for complex standards-based filtering or routing. |
| Headers | Routes messages based on message headers instead of routing keys. Messages are delivered to queues that satisfy the conditions defined in the headers. It is more flexible but less efficient than the Direct or Topic model. |
The table below provides a summary of the methods available on the Devprime Platform Stream Adapter and the features offered to simplify the use of RabbitMQ. Explore each method and the various implementations available to enable the best experience for your design scenario.
| Category | Methods | Description |
|---|---|---|
| Add | AddExchangeRabbitMQ |
Add an exchange on RabbitMQ. |
AddQueueRabbitMQ |
Add a queue in RabbitMQ. | |
AddBindingExchangeQueueRabbitMQ |
Links an exchange to a queue in RabbitMQ. | |
| Subscribe | AddSubscribeRabbitMQ |
Subscribe to a queue on RabbitMQ. |
| Remove | RemoveQueueRabbitMQ |
Removes a queue from RabbitMQ |
RemoveExchangeRabbitMQ |
Removes an exchange from RabbitMQ | |
RemoveSubscribeRabbitMQ |
Removes a subscription in a queue. | |
| Publish | PublishRabbitMQ |
Sends a message to an exchange or queue on RabbitMQ. |
DevPrime.Stack.Foundation.Stream” namespace."The Devprime platform’s ‘AddExchangeRabbitMQ’ method is used to create a new exchange on RabbitMQ. This method supports a variety of exchange types, including Direct, Fanout, Topic, and Headers, allowing for flexible configuration of message routing. In addition, it allows for custom configuration of exchange properties through the ‘CustomExchangeProperties’ class.
The Devprime platform’s ‘AddQueueRabbitMQ’ method is used to create a new queue in RabbitMQ. This method allows you to set custom properties for the queue, giving you flexibility in configuration.
The Devprime platform’s ‘AddBindingExchangeQueueRabbitMQ’ method is used to create a new connection between an exchange and a queue in RabbitMQ. This method allows you to configure the exchange type, routing key, and additional arguments for the binding.
The Devprime platform’s ‘AddSubscribeRabbitMQ’ method is used to subscribe to a queue on an exchange in RabbitMQ. This method creates a subscription that allows the queue to receive messages from the exchange, based on the type of exchange and the routing key provided.
The Devprime platform’s RemoveQueueRabbitMQ method is used to remove an existing queue in RabbitMQ. This method allows you to delete a specific queue, freeing up resources and ensuring that messages are no longer routed to the removed queue.
The Devprime platform’s ‘RemoveExchangeRabbitMQ’ method is used to remove an existing exchange on RabbitMQ. This method deletes the specified exchange, freeing up resources and ensuring that messages are no longer routed through the removed exchange.
The Devprime platform’s ‘RemoveSubscribeRabbitMQ’ method is used to unsubscribe from a queue on an exchange on RabbitMQ. This method removes the existing link between the queue and the exchange, stopping the receipt of messages from the exchange to the queue.
The Devprime platform’s ‘PublishRabbitMQ’ method is used to send messages to an exchange on RabbitMQ. This method allows you to specify the exchange type, routing key, and message properties, ensuring that messages are routed correctly to the associated queues.