summaryrefslogtreecommitdiff
path: root/plugins/jobs/drivers/amqp/rabbit_init.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/drivers/amqp/rabbit_init.go')
-rw-r--r--plugins/jobs/drivers/amqp/rabbit_init.go8
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()
}