rabbitmqhandler

Documentation

Index

• type RabbitMQListner
  • func New(config RabbitMQListnerConfig, handler RabbitMQMessageHandler) RabbitMQListner
  • func (r RabbitMQListner) Listen(hangup chan *amqp.Error)
• type RabbitMQListnerConfig
• type RabbitMQMessageHandler

Types

type RabbitMQListner

type RabbitMQListner struct {
	Client    rabbitmqclient.RabbitMQConnection
	QueueName string
	Consumer  string
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      amqp.Table
	Handler   RabbitMQMessageHandler
}

func New

func New(config RabbitMQListnerConfig, handler RabbitMQMessageHandler) RabbitMQListner

func (RabbitMQListner) Listen

func (r RabbitMQListner) Listen(hangup chan *amqp.Error)

type RabbitMQListnerConfig

type RabbitMQListnerConfig struct {
	Client    rabbitmqclient.RabbitMQConnection
	QueueName string
	Consumer  string
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      amqp.Table
}

type RabbitMQMessageHandler

type RabbitMQMessageHandler interface {
	HandleMessage(ctx context.Context, message amqp.Delivery) error
}