diff options
Diffstat (limited to 'plugins/jobs/brokers/ephemeral/consumer.go')
| -rw-r--r-- | plugins/jobs/brokers/ephemeral/consumer.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/plugins/jobs/brokers/ephemeral/consumer.go b/plugins/jobs/brokers/ephemeral/consumer.go index 5cf4c633..030dcae8 100644 --- a/plugins/jobs/brokers/ephemeral/consumer.go +++ b/plugins/jobs/brokers/ephemeral/consumer.go @@ -98,6 +98,11 @@ func (j *JobBroker) Register(pipeline *pipeline.Pipeline) error { return nil } +// Consume is no-op for the ephemeral +func (j *JobBroker) Consume(_ *pipeline.Pipeline) error { + return nil +} + func (j *JobBroker) Pause(pipeline string) { if q, ok := j.queues.Load(pipeline); ok { if q == true { |