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

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
}