eqmrmq

Sep 4, 2024

Changes in this version

type Message

+ Msg []byte

Sep 1, 2024

Changes in this version

+ const ContentTypeAVIF

+ const ContentTypeGIF

+ const ContentTypeJPEG

+ const ContentTypeJSON

+ const ContentTypeOctetStream

+ const ContentTypePDF

+ const ContentTypePNG

+ const ContentTypeTextCSV

+ const ContentTypeTextHTML

+ const ContentTypeTextPlain

+ const ContentTypeXML

+ const ContentTypeZIP

type Message

+ ContentType contentType

Jun 1, 2024

Changes in this version

+ func Connect(rabbitURL string) (*amqp.Connection, error)

Jun 1, 2024

Changes in this version

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

Jun 1, 2024

Changes in this version

+ func CreateReplyQueue(channel *amqp.Channel) (string, error)

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

+ func GenerateCorrelationId() string

+ func ReceiveResponse(correlationId, replyQueue string, ch *amqp.Channel) ([]byte, error)

+ func RegisterConsumer(ch *amqp.Channel, queueName string) (<-chan amqp.Delivery, error)

type Message

+ func (msg *Message) Publish() error

May 31, 2024

Changes in this version

+ 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 struct

+ Ch *amqp.Channel

+ CorrelationId string

+ Message string

+ QueueName string

+ ReplyQueue string

+ type QueueConfig struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ type RMQService struct

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