Documentation
¶
Index ¶
- type AMQPConnector
- func (ac *AMQPConnector) Close(channel *amqp.Channel, conn *amqp.Connection) error
- func (ac *AMQPConnector) Connect(url string, tlsConfig *tls.Config, exchange, exchangeType, queueName string, ...) (*amqp.Connection, *amqp.Channel, amqp.Queue, <-chan amqp.Confirmation, ...)
- func (ac *AMQPConnector) DeleteQueue(channel *amqp.Channel, queueName string) error
- func (*AMQPConnector) InspectQueue(channel *amqp.Channel, queueName string) (*amqp.Queue, error)
- func (ac *AMQPConnector) Open(url string, tlsConfig *tls.Config) (*amqp.Connection, *amqp.Channel, error)
- type RedisConnector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPConnector ¶
type AMQPConnector struct{}
AMQPConnector ...
func (*AMQPConnector) Close ¶
func (ac *AMQPConnector) Close(channel *amqp.Channel, conn *amqp.Connection) error
Close connection
func (*AMQPConnector) Connect ¶
func (ac *AMQPConnector) Connect(url string, tlsConfig *tls.Config, exchange, exchangeType, queueName string, queueDurable, queueDelete bool, queueBindingKey string, exchangeDeclareArgs, queueDeclareArgs, queueBindingArgs amqp.Table) (*amqp.Connection, *amqp.Channel, amqp.Queue, <-chan amqp.Confirmation, <-chan *amqp.Error, error)
Connect opens a connection to RabbitMQ, declares an exchange, opens a channel, declares and binds the queue and enables publish notifications
func (*AMQPConnector) DeleteQueue ¶
func (ac *AMQPConnector) DeleteQueue(channel *amqp.Channel, queueName string) error
DeleteQueue deletes a queue by name
func (*AMQPConnector) InspectQueue ¶
InspectQueue provides information about a specific queue
Source Files
Click to show internal directories.
Click to hide internal directories.