diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-07 18:33:04 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-07 18:33:04 +0300 |
| commit | 60c229c8506df465586434309af5acd1f84e2406 (patch) | |
| tree | 18fdf380b7e032415d656e84bcc3c7a057f194a8 /plugins/jobs/brokers/amqp/consumer.go | |
| parent | 127186a72d4b8d30f6ada72ade661d8713490728 (diff) | |
Updated ephemeral plugin, PQ and protobuf...
Implement core of the root jobs plugin with a proper drivers/pipelines
handling mechanism.
Add delayed jobs for the ephemeral plugin.
Remove ResumeAll, Resume, StopAll, Stop. Replaced with Pause/Resume with
a slice of the pipelines.
Other small improvements.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/brokers/amqp/consumer.go')
| -rw-r--r-- | plugins/jobs/brokers/amqp/consumer.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/plugins/jobs/brokers/amqp/consumer.go b/plugins/jobs/brokers/amqp/consumer.go new file mode 100644 index 00000000..0e8d02ac --- /dev/null +++ b/plugins/jobs/brokers/amqp/consumer.go @@ -0,0 +1 @@ +package amqp |