Golang скрывает детали реализации канала

Чтобы сделать интерфейс Consumer более абстрактным и менее привязанным к реализации, вы можете ввести новый тип сообщения, не зависящий от конкретной реализации брокера. Вот пример того, как вы можете этого добиться:

type Message interface {
    // Define the methods that your message type should have
    // to work with your application logic.
    // ...
}

type Consumer interface {
    StartConsuming(queueName, key string) (<-chan Message, error)
}

Создавая интерфейс Message, вы можете определить методы, которые должен иметь ваш тип сообщения, чтобы работать с логикой вашего приложения. Это позволяет отделить ваш код от конкретной реализации брокера.

Затем вы можете обновить свою реализацию rabbitmq.Consumer, чтобы она работала с интерфейсом Message вместо amqp.Delivery:

package rabbitmq

type Consumer struct {
    *Connection
}

func (c Consumer) StartConsuming(queueName, key string) (<-chan Message, error) {
    _, err := c.Channel.QueueDeclare(
        queueName,
        true,
        false,
        false,
        false,
        nil,
    )

    ...

    // Convert amqp.Delivery to your custom Message type
    convertToMessage := func(delivery amqp.Delivery) Message {
        // Implement the conversion logic from amqp.Delivery to your custom Message type.
        // ...
    }

    // Get the amqp.Delivery channel
    amqpDelivery, err := c.Connection.Consume(
        queueName,
        "",
        false,
        false,
        false,
        false,
        nil,
    )
    if err != nil {
        return nil, err
    }

    // Create a channel for your custom Message type
    messageChannel := make(chan Message)

    // Start a goroutine to convert amqp.Delivery to your custom Message type
    go func() {
        defer close(messageChannel)
        for delivery := range amqpDelivery {
            message := convertToMessage(delivery)
            messageChannel <- message
        }
    }()

    return messageChannel, nil
}

В приведенном выше коде функция convertToMessage преобразует amqp.Delivery в ваш пользовательский тип Message. Вам нужно будет реализовать эту логику преобразования в зависимости от потребностей вашего приложения.

Используя этот подход, вы можете сохранить свой интерфейс Consumer абстрактным и независимым от конкретной реализации брокера. Вы можете переключиться на другого брокера, например MQTT, предоставив другую реализацию интерфейса Consumer, которая работает с соответствующим типом сообщения для MQTT.

Примечание. Обязательно обновите другие части кода, использующие интерфейс Consumer, чтобы они также работали с типом Message.