Declarer is implemented by *amqp.Channel
| 7 | |
| 8 | // Declarer is implemented by *amqp.Channel |
| 9 | type Declarer interface { |
| 10 | QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error) |
| 11 | ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error |
| 12 | QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error |
| 13 | } |
| 14 | |
| 15 | // DeclareQueue is a way to declare AMQP queue |
| 16 | func DeclareQueue(q *Queue) Declaration { |
no outgoing calls
no test coverage detected