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

	Handler RabbitMQMessageHandler
	// contains filtered or unexported fields
}

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
	QueueAutoDelete    bool
	Exclusive          bool
	NoLocal            bool
	NoWait             bool
	Args               amqp.Table
	Exchange           string
	ExcahngeRoutingKey string
}

type RabbitMQMessageHandler

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