rabbitmq

Documentation

Index

• func ConnectRabbitMQ() *amqp.Connection
• func Consume(ch *amqp.Channel, q amqp.Queue) (<-chan amqp.Delivery, error)
• func DeclareExchange(ch *amqp.Channel, name string, kind string) error
• func DeclareQueue(ch *amqp.Channel, name string) (amqp.Queue, error)
• func OpenChannel(conn *amqp.Connection) (*amqp.Channel, error)
• func Publish(ch *amqp.Channel, exchange string, key string, body RabbitMqBody) error
• func QueueBind(ch *amqp.Channel, q amqp.Queue, key string, exchange string) error
• type RabbitMqBody
• type RabbitMqRouter
  • func NewRouter(ch *amqp.Channel) *RabbitMqRouter
  • func (r *RabbitMqRouter) HandleFunc(exchange string, key string, f func(body RabbitMqBody))
  • func (r *RabbitMqRouter) PublishMessage(exchange string, key string, bodies []RabbitMqBody) error

Functions

func ConnectRabbitMQ

func ConnectRabbitMQ() *amqp.Connection

func Consume

func Consume(ch *amqp.Channel, q amqp.Queue) (<-chan amqp.Delivery, error)

func DeclareExchange

func DeclareExchange(ch *amqp.Channel, name string, kind string) error

func DeclareQueue

func DeclareQueue(ch *amqp.Channel, name string) (amqp.Queue, error)

func OpenChannel

func OpenChannel(conn *amqp.Connection) (*amqp.Channel, error)

func Publish

func Publish(ch *amqp.Channel, exchange string, key string, body RabbitMqBody) error

func QueueBind

func QueueBind(ch *amqp.Channel, q amqp.Queue, key string, exchange string) error

Types

type RabbitMqBody

type RabbitMqBody struct {
	DataVersion string `json:"data_version"`
	Data        any    `json:"data"`
}

type RabbitMqRouter

type RabbitMqRouter struct {
	Channel   *amqp.Channel
	Exchanges map[string]bool
}

func NewRouter

func NewRouter(ch *amqp.Channel) *RabbitMqRouter

func (*RabbitMqRouter) HandleFunc

func (r *RabbitMqRouter) HandleFunc(exchange string, key string, f func(body RabbitMqBody))

func (*RabbitMqRouter) PublishMessage

func (r *RabbitMqRouter) PublishMessage(exchange string, key string, bodies []RabbitMqBody) error