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
Houses the underlying Rabbit MQ Connection
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 |