Function bindQueue

pubsub/rabbitpubsub/rabbit_test.go:275–282

(conn amqpConnection, queueName, exchangeName string)

}

func bindQueue(conn amqpConnection, queueName, exchangeName string) error {
	ch, err := conn.Channel()
	if err != nil {
		return err
	}
	defer ch.Close()
	return ch.QueueDeclareAndBind(queueName, exchangeName)
}

type rabbitAsTest struct {
	usingFake bool