Как привести тип < -chan amqp.Delivery к < -chan interface{}?

Question

[Everything_is_not_so_bad]

Для примера набросал такой код. Цель функции - вернуть канал с интерфейсом, чтобы реализовать абстрактный тип канала.

package main

import (
	"fmt"
	"github.com/streadway/amqp"
)

type (
	IConsumer interface {
		Consume() (<-chan interface{}, error)
	}
	AmqpConsumer struct {
		conn    *amqp.Connection
		topic   string
		channel *amqp.Channel
	}
)

func (pr *AmqpConsumer) Consume() (<-chan interface{}, error) {
	var msgs <-chan interface{}

	ch, err := pr.conn.Channel()
	if err != nil {
		return msgs, err
	}
	defer ch.Close()

	amqp_msgs, err := ch.Consume(
		pr.topic, // queue
		"",       // consumer
		true,     // auto-ack
		false,    // exclusive
		false,    // no-local
		false,    // no-wait
		nil,      // args
	)
	if err != nil {
		return msgs, err
	}

	return amqp_msgs, nil
}

func main() {
	fmt.Println("Hello, playground")
}

https://play.golang.org/p/VTRDQjYOclf

Получаю ошибку

./prog.go:41:2: cannot use amqp_msgs (type <-chan amqp.Delivery) as type <-chan interface {} in return argument

Comments

[Everything_is_not_so_bad]

Или предложите как абстрагировать от AMQP другим путем.

[WinPooh32]

Роман Мирр, делайте полную обертку над amqp пакетом и скрывайте что хотите, но вам все равно придется в явном виде (внутри обертки) повесить обработчик на <-chan amqp.Delivery

Answer 1

[di]

Кастовать каналы вроде как нельзя в go. Придется создавать промежуточный канал. Примерно так я это вижу. Но скорее всего оно не работает так как надо
https://play.golang.org/p/i8-69C6RDrG

package main

import (
	"fmt"
	"github.com/streadway/amqp"
)

type (
	IConsumer interface {
		Consume() (<-chan interface{}, error)
	}
	AmqpConsumer struct {
		conn    *amqp.Connection
		topic   string
		channel *amqp.Channel
	}
)

func (pr *AmqpConsumer) Consume() (<-chan interface{}, error) {
	var msgs <-chan interface{}

	ch, err := pr.conn.Channel()
	if err != nil {
		return msgs, err
	}
	defer ch.Close()

	amqp_msgs, err := ch.Consume(
		pr.topic, // queue
		"",       // consumer
		true,     // auto-ack
		false,    // exclusive
		false,    // no-local
		false,    // no-wait
		nil,      // args
	)
	if err != nil {
		return msgs, err
	}

	var castCh chan interface{}
	go func() {
		for msg := range amqp_msgs {
			castCh <- msg
		}
	}()
	
	return castCh, nil
}

func main() {
	fmt.Println("Hello, playground")
}

Comments

[Everything_is_not_so_bad]

Спасибо. Я проверю.