message

Documentation

Index

• type Message
  • func NewFromDelivery(delivery amqp.Delivery) Message
• type OnMessageHandler

Types

type Message

type Message interface {
	Headers() *map[string]string
	Body() body.Body

	Ack() error
	Nack(requeue bool) error
}

Message represents the message interface

func NewFromDelivery

func NewFromDelivery(delivery amqp.Delivery) Message

NewFromDelivery creates a new message instance from delivery

type OnMessageHandler

type OnMessageHandler func(Message) error

OnMessageHandler represents a handler when RabbitMQ receive a message