summaryrefslogtreecommitdiff
path: root/plugins/jobs/brokers/amqp/consumer.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-12 14:57:24 +0300
committerValery Piashchynski <[email protected]>2021-07-12 14:57:24 +0300
commitec7c049036d31fe030d106db9f0d268ea0296c5f (patch)
treec7772e6e2c734c3df5ce207fb6690d5891b57c6d /plugins/jobs/brokers/amqp/consumer.go
parent0be3e79115345d13e92da9b8a4e2b0926480c138 (diff)
Add JOBS tests to the Makefile and GitHub CI.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/brokers/amqp/consumer.go')
-rw-r--r--plugins/jobs/brokers/amqp/consumer.go9
1 files changed, 9 insertions, 0 deletions
diff --git a/plugins/jobs/brokers/amqp/consumer.go b/plugins/jobs/brokers/amqp/consumer.go
index 481e102a..c2807b54 100644
--- a/plugins/jobs/brokers/amqp/consumer.go
+++ b/plugins/jobs/brokers/amqp/consumer.go
@@ -422,6 +422,15 @@ func (j *JobsConsumer) Resume(p string) {
func (j *JobsConsumer) Stop() error {
j.stopCh <- struct{}{}
+
+ pipe := j.pipeline.Load().(*pipeline.Pipeline)
+ j.eh.Push(events.JobEvent{
+ Event: events.EventPipeStopped,
+ Driver: pipe.Driver(),
+ Pipeline: pipe.Name(),
+ Start: time.Now(),
+ Elapsed: 0,
+ })
return nil
}