diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-13 22:15:21 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-08-13 22:15:21 +0300 |
| commit | 6860326fa5d8f37f6e954da07fd53b9261731227 (patch) | |
| tree | bb5fe7dde56edb1e8c3b55a21a874bbbaeda3a3b /plugins/jobs/drivers/amqp/rabbit_init.go | |
| parent | de378e7698db896b8fd16f628c7d89689c8371d0 (diff) | |
| parent | 849b20c354faf81f2bcf101fba025ae425e33e85 (diff) | |
#762: fix(tests): update gomock with tests, update all deps in the `go.mod`
#762: fix(tests): update gomock with tests, update all deps in the `go.mod`
Diffstat (limited to 'plugins/jobs/drivers/amqp/rabbit_init.go')
| -rw-r--r-- | plugins/jobs/drivers/amqp/rabbit_init.go | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/plugins/jobs/drivers/amqp/rabbit_init.go b/plugins/jobs/drivers/amqp/rabbit_init.go index 570498e9..56ef10c8 100644 --- a/plugins/jobs/drivers/amqp/rabbit_init.go +++ b/plugins/jobs/drivers/amqp/rabbit_init.go @@ -1,10 +1,7 @@ package amqp import ( - "time" - "github.com/spiral/errors" - "github.com/spiral/roadrunner/v2/pkg/events" ) func (j *JobConsumer) initRabbitMQ() error { @@ -56,10 +53,5 @@ func (j *JobConsumer) initRabbitMQ() error { return errors.E(op, err) } - j.eh.Push(events.JobEvent{ - Event: events.EventInitialized, - Driver: "amqp", - Start: time.Now(), - }) return channel.Close() } |