Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMqConfig ¶ added in v0.2.2
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 ¶ added in v0.3.1
type RabbitMqEventHandler struct { worker.BaseHandler MqMessage *amqp.Delivery }
func (*RabbitMqEventHandler) SetMqMessage ¶ added in v0.3.1
func (h *RabbitMqEventHandler) SetMqMessage(m *amqp.Delivery)
type RabbitMqEventHandlerInterface ¶ added in v0.3.1
type RabbitMqEventHandlerInterface interface { worker.BaseHandlerInterface SetMqMessage(*amqp.Delivery) }
type RabbitMqEventWorker ¶ added in v0.2.2
type RabbitMqEventWorker struct { *worker.BaseWorker // contains filtered or unexported fields }
func NewRabbitMqEventWorker ¶ added in v0.2.2
func NewRabbitMqEventWorker(name string, config *RabbitMqConfig) *RabbitMqEventWorker
func (*RabbitMqEventWorker) Run ¶ added in v0.2.2
func (w *RabbitMqEventWorker) Run()
func (*RabbitMqEventWorker) SetEvent ¶ added in v0.2.2
func (w *RabbitMqEventWorker) SetEvent(queue string, routingKey string, handler RabbitMqEventHandlerInterface)
func (*RabbitMqEventWorker) Setup ¶ added in v0.2.2
func (w *RabbitMqEventWorker) Setup()
func (*RabbitMqEventWorker) Stop ¶ added in v0.2.2
func (w *RabbitMqEventWorker) Stop()
Click to show internal directories.
Click to hide internal directories.