Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2023 v0.0.3 Apr 28, 2022 v0.0.2 Mar 9, 2022 Changes in this version + type AmqpChannel struct + func NewAmqpChannel(amqpConnection *AmqpConnection) *AmqpChannel + func (c *AmqpChannel) AddConsumer(queueName string, consumerName string, prefetch int) chan amqp.Delivery + func (c *AmqpChannel) Bind(queueName string, routingKey string, exchangeName string) error + func (c *AmqpChannel) DeclareExchange(exchangeName, kind string, durable, autoDelete bool) error + func (c *AmqpChannel) DeclareQueue(queueName string, durable bool, autoDelete bool) (string, error) + func (c *AmqpChannel) DeleteExchange(exchangeName string, ifUnused bool) error + func (c *AmqpChannel) DeleteQueue(queueName string, ifUnused bool, ifEmpty bool) error + func (c *AmqpChannel) Disconnect() + func (c *AmqpChannel) RemoveConsumer(consumerName string) + func (c *AmqpChannel) SendToExchange(exchangeName string, routingKey string, body string) error + func (c *AmqpChannel) SendToExchangeWithType(exchangeName string, routingKey string, body string, contentType string) error + func (c *AmqpChannel) SendToQueue(queueName string, body string) error + func (c *AmqpChannel) SendToQueueWithType(queueName string, body string, contentType string) error + func (c *AmqpChannel) Unbind(queueName string, routingKey string, exchangeName string) error + type AmqpConnectOption struct + Host string + Password string + Port int + Username string + Vhost string + type AmqpConnection struct + func NewAmqpConnection(option AmqpConnectOption, logID string) *AmqpConnection + func (c *AmqpConnection) Disconnect()