Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPChannel ¶
type AMQPChannel interface { Close() error Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error) Tx() error TxCommit() error TxRollback() error }
AMQPChannel represents the needed functionality from a amqp.Channel
type AMQPConnection ¶
AMQPConnection represents the needed functionality from a amqp.Connection
type AMQPDelivery ¶
AMQPDelivery represents the needed functionality from a amqp.Delivery
Click to show internal directories.
Click to hide internal directories.