Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
houseofcat committed Mar 17, 2024
1 parent c03d89e commit da72df5
Show file tree
Hide file tree
Showing 122 changed files with 12 additions and 5 deletions.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
4 changes: 2 additions & 2 deletions src/HouseofCat.RabbitMQ/Pools/ConnectionPool.cs
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ public ConnectionPool(RabbitOptions options, HttpClientHandler oauth2ClientHandl

if (oauth2ClientHandler is not null)
{

_connectionFactory = BuildConnectionFactory(options, oauth2ClientHandler);
}
else
{
Expand Down Expand Up @@ -114,7 +114,7 @@ protected virtual ConnectionFactory BuildConnectionFactory()
return cf;
}

protected virtual ConnectionFactory CreateConnectionFactory(RabbitOptions options, HttpClientHandler oauth2ClientHandler)
protected virtual ConnectionFactory BuildConnectionFactory(RabbitOptions options, HttpClientHandler oauth2ClientHandler)
{
var oAuth2ClientBuilder = new OAuth2ClientBuilder(
Options.FactoryOptions.OAuth2Options.ClientId,
Expand Down
13 changes: 10 additions & 3 deletions src/HouseofCat.RabbitMQ/SampleConfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,12 @@
"NetRecoveryTimeout": 10,
"ContinuationTimeout": 10,
"EnableDispatchConsumersAsync": true,
"OAuth2Options": {
"TokenEndpointUrl": false,
"ClientId": "",
"ClientSecret": ""
},
"SslOptions": {
"EnableSsl": false,
"CertServerName": "",
"LocalCertPath": "",
"LocalCertPassword": "",
Expand All @@ -19,8 +23,11 @@
"PoolOptions": {
"ServiceName": "HoC.RabbitMQ",
"MaxConnections": 5,
"MaxChannels": 25,
"SleepOnErrorInterval": 1000
"MaxChannels": 0,
"MaxAckChannels": 0,
"SleepOnErrorInterval": 1000,
"TransientStartChanelRange": 10000,
"UseTransientChannels": false
},
"PublisherOptions": {
"LetterQueueBufferSize": 100,
Expand Down

0 comments on commit da72df5

Please sign in to comment.