nsq

type Consumer interface {
	SubscribeMsg(topic string, cmd func([]byte) error) error
}

type NsqClient interface {
	NsqProducer() (*nsq.Producer, error)
	NsqConsumer(topic string, ch string) (*nsq.Consumer, error)
	GetNsqProducerLink() string
	GetNsqConsumerLink() string
}

type Publish interface {
	PublishMsg(topic string, msg interface{}) (err error)
}