diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-12 09:38:47 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-12 09:38:47 +0300 |
| commit | bf2f7167ae49ecac981c7c18a9b9b496fd0a514c (patch) | |
| tree | 9c5c11ab7984df0775d62553808fc95d395e20d5 /plugins/jobs/drivers/amqp/config.go | |
| parent | 2d460062c97f9ad1e793831c54ae4d177dea83e8 (diff) | |
Made QoS production like
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/drivers/amqp/config.go')
| -rw-r--r-- | plugins/jobs/drivers/amqp/config.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/amqp/config.go b/plugins/jobs/drivers/amqp/config.go index 3fb0d066..73482d4d 100644 --- a/plugins/jobs/drivers/amqp/config.go +++ b/plugins/jobs/drivers/amqp/config.go @@ -38,6 +38,7 @@ type Config struct { } func (c *Config) InitDefault() { + // all options should be in sync with the pipeline defaults in the FromPipeline method if c.ExchangeType == "" { c.ExchangeType = "direct" } @@ -47,7 +48,7 @@ func (c *Config) InitDefault() { } if c.Prefetch == 0 { - c.Prefetch = 100 + c.Prefetch = 10 } if c.Priority == 0 { |