common

Aug 27, 2017

Changes in this version

+ type AMQPConnector struct

+ func (*AMQPConnector) InspectQueue(channel *amqp.Channel, queueName string) (*amqp.Queue, error)

+ 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 (ac *AMQPConnector) Open(url string, tlsConfig *tls.Config) (*amqp.Connection, *amqp.Channel, error)

+ type RedisConnector struct

+ func (rc *RedisConnector) NewPool(socketPath, host, password string, db int) *redis.Pool