MQContract.RabbitMQ
This is the MessageServiceConnection implemenation for using RabbitMQ
Default constructor for creating instance
Name | Type | Description |
---|---|---|
factory | RabbitMQ.Client.ConnectionFactory | The connection factory to use that was built with required authentication and connection information |
The default timeout to use for RPC calls when not specified by class or in the call. DEFAULT: 1 minute
The maximum message body size allowed
Used to decalre an exchange inside the RabbitMQ server
The connection to allow for chaining calls
Name | Type | Description |
---|---|---|
exchange | System.String | The name of the exchange |
type | System.String | The type of the exchange |
durable | System.Boolean | Is this durable |
autoDelete | System.Boolean | Auto Delete when connection closed |
arguments | System.Collections.Generic.IDictionary{System.String,System.Object} | Additional arguements |
Used to declare a queue inside the RabbitMQ server
The connection to allow for chaining calls
Name | Type | Description |
---|---|---|
queue | System.String | The name of the queue |
durable | System.Boolean | Is this queue durable |
exclusive | System.Boolean | Is this queue exclusive |
autoDelete | System.Boolean | Auto Delete queue when connection closed |
arguments | System.Collections.Generic.IDictionary{System.String,System.Object} | Additional arguements |
Used to delete a queue inside the RabbitMQ server
Name | Type | Description |
---|---|---|
queue | System.String | The name of the queue |
ifUnused | System.Boolean | Is unused |
ifEmpty | System.Boolean | Is Empty |