diff options
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 { |