Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel interface { ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error ExchangeDelete(name string, ifUnused, noWait bool) error ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error ExchangeUnbind(destination, key, source string, noWait bool, args amqp.Table) error QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error) QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error QueueUnbind(name, key, exchange string, args amqp.Table) error QueuePurge(name string, noWait bool) (int, error) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error Confirm(noWait bool) error NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error) Ack(tag uint64, multiple bool) error Nack(tag uint64, multiple bool, requeue bool) error Close() error }
type Connection ¶
func NewConnection ¶
func NewConnection(url string) (Connection, error)
type ConnectionWrapper ¶
type ConnectionWrapper struct {
*amqp.Connection
}
func (*ConnectionWrapper) Channel ¶
func (w *ConnectionWrapper) Channel() (Channel, error)
Click to show internal directories.
Click to hide internal directories.