mq

type IKProducer interface {
	IMQWorker
	Setup(_zk_addrs string)
	Push(_topic *string, _part int, _key, _val []byte)
}

type IKmqConsumer interface {
	IMQWorker
	Setup(_zks, _app, _group string, _receiver chan KMessage)
	Subscribe(_topic string)
}

type IMQWorker interface {
	Start()
	Stop()
}

type IRmqConsumer interface {
	IMQWorker
	Setup(_name_svr, _app, _group string, _receiver chan RMessage)
	Subscribe(_topic string, _need bool)
}

type IRmqProducer interface {
	IMQWorker
	Setup(_key, _name_svr string)
	Push(_topic *string, _flag, _key, _val []byte)
}

type KMessage *kmq.ConsumerMessage

type RMessage *rmq.MessageExt