diff options
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() } |