nsq

type Client interface {
	// SyncSendMsg is used to send a message to the server
	SyncSendMsg(topic string, data []byte, delay time.Duration) error
	// ConsumerMsg is used to consume messages from the server
	ConsumerMsg(topic, channel string, lookUpAddrs []string,
		handler nsq.Handler) (*nsq.Consumer, error)
	// StopProducerList is used to stop the producer list gracefully
	StopProducerList()
}

type ClientNsq struct {
	// contains filtered or unexported fields
}