Documentation
¶
Index ¶
Constants ¶
View Source
const ( ExchangeFanout ExchangeType = amqp091.ExchangeFanout ExchangeDirect = amqp091.ExchangeDirect ExchangeTopic = amqp091.ExchangeTopic )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExchangeType ¶
type ExchangeType string
type IConnection ¶
type IConnection interface {
IsClosed() bool
IsConnected() bool
// Channel gets a new channel on this internalConnection
Channel() (*amqp091.Channel, error)
Close() error
ReConnect() error
NotifyClose(receiver chan *amqp091.Error) chan *amqp091.Error
Raw() *amqp091.Connection
ErrorConnectionChannel() chan error
ReconnectedChannel() chan struct{}
}
func NewRabbitMQConnection ¶
func NewRabbitMQConnection(cfg *config.RabbitmqOptions) (IConnection, error)
Source Files
Click to show internal directories.
Click to hide internal directories.