MQContract.RabbitMQ
1.1.0
dotnet add package MQContract.RabbitMQ --version 1.1.0
NuGet\Install-Package MQContract.RabbitMQ -Version 1.1.0
<PackageReference Include="MQContract.RabbitMQ" Version="1.1.0" />
paket add MQContract.RabbitMQ --version 1.1.0
#r "nuget: MQContract.RabbitMQ, 1.1.0"
// Install MQContract.RabbitMQ as a Cake Addin #addin nuget:?package=MQContract.RabbitMQ&version=1.1.0 // Install MQContract.RabbitMQ as a Cake Tool #tool nuget:?package=MQContract.RabbitMQ&version=1.1.0
<a name='assembly'></a>
MQContract.RabbitMQ
Contents
<a name='T-MQContract-RabbitMQ-Connection'></a>
Connection type
Namespace
MQContract.RabbitMQ
Summary
This is the MessageServiceConnection implemenation for using RabbitMQ
<a name='M-MQContract-RabbitMQ-Connection-#ctor-RabbitMQ-Client-ConnectionFactory-'></a>
#ctor(factory) constructor
Summary
Default constructor for creating instance
Parameters
Name | Type | Description |
---|---|---|
factory | RabbitMQ.Client.ConnectionFactory | The connection factory to use that was built with required authentication and connection information |
<a name='P-MQContract-RabbitMQ-Connection-DefaultTimeout'></a>
DefaultTimeout property
Summary
The default timeout to use for RPC calls when not specified by class or in the call. DEFAULT: 1 minute
<a name='P-MQContract-RabbitMQ-Connection-MaxMessageBodySize'></a>
MaxMessageBodySize property
Summary
The maximum message body size allowed
<a name='M-MQContract-RabbitMQ-Connection-ExchangeDeclare-System-String,System-String,System-Boolean,System-Boolean,System-Collections-Generic-IDictionary{System-String,System-Object}-'></a>
ExchangeDeclare(exchange,type,durable,autoDelete,arguments) method
Summary
Used to decalre an exchange inside the RabbitMQ server
Returns
The connection to allow for chaining calls
Parameters
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 |
<a name='M-MQContract-RabbitMQ-Connection-QueueDeclare-System-String,System-Boolean,System-Boolean,System-Boolean,System-Collections-Generic-IDictionary{System-String,System-Object}-'></a>
QueueDeclare(queue,durable,exclusive,autoDelete,arguments) method
Summary
Used to declare a queue inside the RabbitMQ server
Returns
The connection to allow for chaining calls
Parameters
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 |
<a name='M-MQContract-RabbitMQ-Connection-QueueDelete-System-String,System-Boolean,System-Boolean-'></a>
QueueDelete(queue,ifUnused,ifEmpty) method
Summary
Used to delete a queue inside the RabbitMQ server
Parameters
Name | Type | Description |
---|---|---|
queue | System.String | The name of the queue |
ifUnused | System.Boolean | Is unused |
ifEmpty | System.Boolean | Is Empty |
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
-
net8.0
- MQContract.Abstractions (>= 1.1.0)
- RabbitMQ.Client (>= 6.8.1)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
1.1.0 | 91 | 10/3/2024 |