diff options
author | Valery Piashchynski <[email protected]> | 2021-07-08 17:54:29 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-07-08 17:54:29 +0300 |
commit | 4566f88004e81d3229222d82614c15346ac2e47d (patch) | |
tree | 05dc6ffeea8d00cb63cc6a51c17ae2afda8aaa5a /tests | |
parent | 5f84c5d5709cff5984a5859651a0bbb1c55fcb0f (diff) |
AMQP update...
Add redialer, consumer, rabbit queues initializer.
Update configuration (.rr.yaml).
Add ack/nack for the jobs main plugin with error handling.
Add Qos, queues bining and declaration.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests')
-rw-r--r-- | tests/plugins/jobs/configs/.rr-jobs-init.yaml | 6 | ||||
-rw-r--r-- | tests/plugins/kv/rr.db | bin | 0 -> 32768 bytes |
2 files changed, 5 insertions, 1 deletions
diff --git a/tests/plugins/jobs/configs/.rr-jobs-init.yaml b/tests/plugins/jobs/configs/.rr-jobs-init.yaml index 90590ccb..1648fa6c 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-init.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-init.yaml @@ -9,6 +9,7 @@ server: amqp: addr: amqp://guest:guest@localhost:5672/ + # beanstalk configuration beanstalk: addr: tcp://localhost:11300 @@ -45,7 +46,10 @@ jobs: test-1: driver: amqp priority: 1 - queue: default + queue: test-1-queue + exchange: default + exchange_type: direct + routing_key: test pipeline_size: 1000000 test-2: diff --git a/tests/plugins/kv/rr.db b/tests/plugins/kv/rr.db Binary files differnew file mode 100644 index 00000000..4267eb2c --- /dev/null +++ b/tests/plugins/kv/rr.db |