rabbitmq

type RabbitMqConfig struct {
	Host          string `json:"Host,omitempty" config:"Host,required"`
	Port          int16  `json:"Port,omitempty" config:"Port,required"`
	Username      string `json:"Username,omitempty" config:"Username,required"`
	Password      string `json:"Password,omitempty" config:"Password,required"`
	PrefetchCount int    `json:"PrefetchCount,omitempty" config:"PrefetchCount"`
}

type RabbitMqEventHandler struct {
	worker.BaseHandler

	MqMessage *amqp.Delivery
}

type RabbitMqEventHandlerInterface interface {
	worker.BaseHandlerInterface

	SetMqMessage(*amqp.Delivery)
}

type RabbitMqEventWorker struct {
	*worker.BaseWorker
	// contains filtered or unexported fields
}