后端消息队列可以改成接口吗

[lchjczw]

后端消息队列可以改成接口吗，后面有些情况下，可以用其他消息队列

[fanux]

func (mq *Mq) Publish(key string, v MqHandler) error {
    return mq.conn.Publish(key, v)
}

func (mq *Mq) Subscribe(key string, v MqHandler) (*nats.Subscription, error) {
    return mq.conn.Subscribe(key, v)
}

/*
func (mq *Mq) Unsubscribe(sub *nats.Subscription) error {
    return sub.Unsubscribe()
}
*/

func (mq *Mq) Unsubscribe(handle interface{}) error {
    c :=handle.(*nats.Subscription)
    return c.Unsubscribe()
}

确实可以抽象成接口，有兴趣可参与这个项目进行改造