diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-01 19:12:40 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-01 19:12:40 +0300 |
| commit | c90c11b92e229280477a9b049e65ca1048825dd4 (patch) | |
| tree | 2a38695cad6dc3095b291575cfb40bc56820d86d /plugins/jobs/drivers/amqp/item.go | |
| parent | 1e59ec2755a9cdafd26864ba532fa4d3eff46ecd (diff) | |
Rework vec based on the channel. Use select statement with the default
branch to handle dead workers inside the channel.
Update docker-compose.yaml used for the tests. Update rabbitmq to 3.9.1.
Replace third-party amqp091 with the official implementation.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/drivers/amqp/item.go')
| -rw-r--r-- | plugins/jobs/drivers/amqp/item.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/amqp/item.go b/plugins/jobs/drivers/amqp/item.go index 295ccfd3..6b544620 100644 --- a/plugins/jobs/drivers/amqp/item.go +++ b/plugins/jobs/drivers/amqp/item.go @@ -4,10 +4,10 @@ import ( "time" json "github.com/json-iterator/go" + amqp "github.com/rabbitmq/amqp091-go" "github.com/spiral/errors" "github.com/spiral/roadrunner/v2/plugins/jobs/job" "github.com/spiral/roadrunner/v2/utils" - "github.com/streadway/amqp" ) type Item struct { |