summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-08 17:54:29 +0300
committerValery Piashchynski <[email protected]>2021-07-08 17:54:29 +0300
commit4566f88004e81d3229222d82614c15346ac2e47d (patch)
tree05dc6ffeea8d00cb63cc6a51c17ae2afda8aaa5a /tests
parent5f84c5d5709cff5984a5859651a0bbb1c55fcb0f (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.yaml6
-rw-r--r--tests/plugins/kv/rr.dbbin0 -> 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
new file mode 100644
index 00000000..4267eb2c
--- /dev/null
+++ b/tests/plugins/kv/rr.db
Binary files differ