diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-18 11:32:44 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-18 11:32:44 +0300 |
| commit | 9c51360f9119a4114bdcc21c8e61f0908a3c876d (patch) | |
| tree | ea63a051931bbd8282d64478bbefa2f970fcc955 /plugins/jobs/drivers/amqp/consumer.go | |
| parent | f4feb30197843d05eb308081ee579d3a9e3d6206 (diff) | |
Started beanstalk driver. Add new Queue impl (not finished yet).
Fix bugs in the AMQP, update proto-api
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/drivers/amqp/consumer.go')
| -rw-r--r-- | plugins/jobs/drivers/amqp/consumer.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/amqp/consumer.go b/plugins/jobs/drivers/amqp/consumer.go index 20dcef2a..6def138e 100644 --- a/plugins/jobs/drivers/amqp/consumer.go +++ b/plugins/jobs/drivers/amqp/consumer.go @@ -141,7 +141,7 @@ func FromPipeline(pipeline *pipeline.Pipeline, log logger.Logger, cfg config.Con delayCache: make(map[string]struct{}, 100), } - // if no global section + // only global section if !cfg.Has(pluginName) { return nil, errors.E(op, errors.Str("no global amqp configuration, global configuration should contain amqp addrs")) } |