diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-11 22:03:34 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-11 22:03:34 +0300 |
| commit | 2d460062c97f9ad1e793831c54ae4d177dea83e8 (patch) | |
| tree | d796a11941fab4be668843a3fcbd83ea0859db39 /tests/plugins/jobs/amqp | |
| parent | e855ae9fe5673bd95f45f9a265259cb5ecdc9f81 (diff) | |
Durable requeue algo. Update AMQP and Beanstalk tests to use mock
logger. Fix bugs discovered during testing.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins/jobs/amqp')
| -rw-r--r-- | tests/plugins/jobs/amqp/.rr-amqp-declare.yaml | 2 | ||||
| -rw-r--r-- | tests/plugins/jobs/amqp/.rr-amqp-init.yaml | 4 | ||||
| -rw-r--r-- | tests/plugins/jobs/amqp/.rr-amqp-jobs-err.yaml | 24 |
3 files changed, 27 insertions, 3 deletions
diff --git a/tests/plugins/jobs/amqp/.rr-amqp-declare.yaml b/tests/plugins/jobs/amqp/.rr-amqp-declare.yaml index 32883ce2..f9a7308b 100644 --- a/tests/plugins/jobs/amqp/.rr-amqp-declare.yaml +++ b/tests/plugins/jobs/amqp/.rr-amqp-declare.yaml @@ -2,7 +2,7 @@ rpc: listen: tcp://127.0.0.1:6001 server: - command: "php ../../client.php echo pipes" + command: "php ../../jobs_ok.php" relay: "pipes" relay_timeout: "20s" diff --git a/tests/plugins/jobs/amqp/.rr-amqp-init.yaml b/tests/plugins/jobs/amqp/.rr-amqp-init.yaml index c06b5a79..43840545 100644 --- a/tests/plugins/jobs/amqp/.rr-amqp-init.yaml +++ b/tests/plugins/jobs/amqp/.rr-amqp-init.yaml @@ -2,7 +2,7 @@ rpc: listen: tcp://127.0.0.1:6001 server: - command: "php ../../client.php echo pipes" + command: "php ../../jobs_ok.php" relay: "pipes" relay_timeout: "20s" @@ -15,7 +15,7 @@ logs: mode: development jobs: - num_pollers: 10 + num_pollers: 1 pipeline_size: 100000 timeout: 1 pool: diff --git a/tests/plugins/jobs/amqp/.rr-amqp-jobs-err.yaml b/tests/plugins/jobs/amqp/.rr-amqp-jobs-err.yaml new file mode 100644 index 00000000..79493d96 --- /dev/null +++ b/tests/plugins/jobs/amqp/.rr-amqp-jobs-err.yaml @@ -0,0 +1,24 @@ +rpc: + listen: tcp://127.0.0.1:6001 + +server: + command: "php ../../jobs_err.php" + relay: "pipes" + relay_timeout: "20s" + +amqp: + addr: amqp://guest:[email protected]:5672/ + +logs: + level: debug + encoding: console + mode: development + +jobs: + num_pollers: 1 + pipeline_size: 100000 + pool: + num_workers: 10 + max_jobs: 0 + allocate_timeout: 60s + destroy_timeout: 60s |