mynsq

func GetConsumeSize ¶

func GetConsumeSize() int

func ProduceMsg ¶

func ProduceMsg(topic string, message []byte) bool

发消息

func StartConsumeMsg ¶

func StartConsumeMsg(index int, topic, channel, nsqd string, handler nsq.Handler) bool

单个nsqd处理消息 index 表示consumer 索引(用于开关使用)

func StopAllConsumeMsg ¶

func StopAllConsumeMsg()

停止所有topic的全部消费

func StopConsumeMsgByIndex ¶

func StopConsumeMsgByIndex(index int)

停止消费

func StopConsumeMsgByTopic ¶

func StopConsumeMsgByTopic(topic string)

停止某个topic下全部消费