eqmrmq

README

README

Documentation

Index

• func ConsumeMessages(ch *amqp.Channel, queueName string, ...) error
• func ReplyToMessage(ch *amqp.Channel, d amqp.Delivery, replyData []byte) error
• func SendMessage(msgParams Message) error
• func SendToQueueWithResponse(queueName, message string, ch *amqp.Channel) ([]byte, error)
• type Message
• type QueueConfig
• type RMQService
  • func NewRabbitMQService(conn *amqp.Connection, queueConfigs []QueueConfig) (*RMQService, error)

Functions

func ConsumeMessages

func ConsumeMessages(ch *amqp.Channel, queueName string, handler func(*amqp.Channel, amqp.Delivery) error) error

func ReplyToMessage

func ReplyToMessage(ch *amqp.Channel, d amqp.Delivery, replyData []byte) error

func SendMessage

func SendMessage(msgParams Message) error

func SendToQueueWithResponse

func SendToQueueWithResponse(queueName, message string, ch *amqp.Channel) ([]byte, error)

Types

type Message

type Message struct {
	QueueName     string
	Message       string
	CorrelationId string
	ReplyQueue    string
	Ch            *amqp.Channel
}

type QueueConfig

type QueueConfig struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table
}

type RMQService

type RMQService struct {
	// contains filtered or unexported fields
}

func NewRabbitMQService

func NewRabbitMQService(conn *amqp.Connection, queueConfigs []QueueConfig) (*RMQService, error)