diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-10 01:18:56 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-10 01:18:56 +0300 |
| commit | 4fcb5979fad87f6e268f5b9df91ee2ee91e9ef16 (patch) | |
| tree | 30ed85120f8a39fd07756af9f5ce3422cf318971 /tests/plugins | |
| parent | 4566f88004e81d3229222d82614c15346ac2e47d (diff) | |
AMQP job driver...
Update main driver's interface, add Consume(*pipeline) method. Implement
it on the amqp and ephemeral drivers.
Fix error with incorrect order of Register <-> Consume method calls.
Implement rabbitMQ driver, add timeouts, dead-letter-exchange,
packing-unpacking of the amqp messages.
Implement AMQP redialer in case of network error as well as channels
re-creation.
Update drawio diagram.
Update .rr.yaml jobs configuration, add all amqp options. Implement
Ack/Nack.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins')
| -rw-r--r-- | tests/plugins/jobs/configs/.rr-jobs-init.yaml | 16 | ||||
| -rw-r--r-- | tests/plugins/jobs/jobs_plugin_test.go | 4 |
2 files changed, 16 insertions, 4 deletions
diff --git a/tests/plugins/jobs/configs/.rr-jobs-init.yaml b/tests/plugins/jobs/configs/.rr-jobs-init.yaml index 1648fa6c..37fce8e2 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-init.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-init.yaml @@ -41,16 +41,26 @@ jobs: test-local: driver: ephemeral priority: 10 - pipeline_size: 10 + pipeline_size: 10000 + + test-local-2: + driver: ephemeral + priority: 1 + pipeline_size: 10000 + + test-local-3: + driver: ephemeral + priority: 2 + pipeline_size: 10000 test-1: driver: amqp priority: 1 + pipeline_size: 1000000 queue: test-1-queue exchange: default exchange_type: direct routing_key: test - pipeline_size: 1000000 test-2: driver: beanstalk @@ -66,5 +76,5 @@ jobs: queue: default # list of pipelines to be consumed by the server, keep empty if you want to start consuming manually - consume: [ "test-local" ] + consume: [ "test-local", "test-local-2", "test-local-3", "test-1" ] diff --git a/tests/plugins/jobs/jobs_plugin_test.go b/tests/plugins/jobs/jobs_plugin_test.go index 754f60bc..b2f05f0f 100644 --- a/tests/plugins/jobs/jobs_plugin_test.go +++ b/tests/plugins/jobs/jobs_plugin_test.go @@ -11,6 +11,7 @@ import ( endure "github.com/spiral/endure/pkg/container" "github.com/spiral/roadrunner/v2/plugins/config" "github.com/spiral/roadrunner/v2/plugins/jobs" + "github.com/spiral/roadrunner/v2/plugins/jobs/brokers/amqp" "github.com/spiral/roadrunner/v2/plugins/jobs/brokers/ephemeral" "github.com/spiral/roadrunner/v2/plugins/logger" rpcPlugin "github.com/spiral/roadrunner/v2/plugins/rpc" @@ -34,6 +35,7 @@ func TestJobsInit(t *testing.T) { &logger.ZapLogger{}, &jobs.Plugin{}, &ephemeral.Plugin{}, + &amqp.Plugin{}, ) assert.NoError(t, err) @@ -82,7 +84,7 @@ func TestJobsInit(t *testing.T) { } }() - time.Sleep(time.Second * 60) + time.Sleep(time.Second * 120) stopCh <- struct{}{} |