Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel interface { DeclareQueue(name string) error DeclareExchange(name string) error BindQueue(queue, exchange string) error BufferCapacity(value uint16) error Consume(consumerID, queue string) (<-chan amqp.Delivery, error) Ack(deliveryTag uint64, multiple bool) error CancelConsumer(consumerID string) error Publish(exchange, key string, envelope amqp.Publishing) error Tx() error TxCommit() error TxRollback() error io.Closer }
Click to show internal directories.
Click to hide internal directories.