CookedRabbit.Core (Legacy)
Date: 05/01/2022
CookedRabbit.Core
This is the migrated CookedRabbit.Core development.
Original Repo is located at:
https://github.com/houseofcat/CookedRabbit/tree/develop/NetCore/CookedRabbit.Core
Development Details
- RabbitMQ Server v3.8.5
- Erlang 23.0
- NetCore 3.1 (Primarily) / NET 5.0
- C# 8.0-9.0 w/ Visual Studio 2019 Enterprise
New Global behaviors are now addable via config. See PipelineClient in examples folder for full details. This will help reduce config clutter with consumers all sharing the same behavior/settings.
"GlobalConsumerSettings": {
"AggressiveSettings": {
"ErrorSuffix": "Error",
"BatchSize": 128,
"BehaviorWhenFull": 0,
"SleepOnIdleInterval": 0,
"UseTransientChannels": true,
"AutoAck": false,
"NoLocal": false,
"Exclusive": false,
"GlobalConsumerPipelineSettings": {
"WaitForCompletion": false,
"MaxDegreesOfParallelism": 64
}
},
"SingleThreaded": {
"ErrorSuffix": "Error",
"BatchSize": 1,
"BehaviorWhenFull": 0,
"SleepOnIdleInterval": 0,
"UseTransientChannels": true,
"AutoAck": false,
"NoLocal": false,
"Exclusive": false,
"GlobalConsumerPipelineSettings": {
"WaitForCompletion": true,
"MaxDegreesOfParallelism": 1
}
}
},
"ConsumerSettings": {
"ConsumerFromConfig": {
"Enabled": true,
"GlobalSettings": "AggressiveSettings",
"ConsumerName": "ConsumerFromConfig",
"QueueName": "TestRabbitServiceQueue"
}
}