mq

Documentation

Index

• type ConsumerTopicModel
• type MQConsumer
  • func NewMQConsumer(kind string, cluster string, confPath string, logPath string, ...) MQConsumer
• type MQProducer
  • func NewMQProducer(kind string, cluster string, logPath string, confPath string, topics []string) MQProducer

Types

type ConsumerTopicModel

type ConsumerTopicModel struct {
	Group string
	Topic string
}

type MQConsumer

type MQConsumer interface {
	RegisterByTopic(topic string, callback mq.IConsumerCallback) error
	Register(callback mq.IConsumerCallback) error
	Start() error
	Close() error
}

func NewMQConsumer

func NewMQConsumer(kind string, cluster string, confPath string, logPath string, topicModels []*ConsumerTopicModel) MQConsumer

type MQProducer

type MQProducer interface {
	Start() error
	Close() error
	Produce(topic string, msg string) error
}

func NewMQProducer

func NewMQProducer(kind string, cluster string, logPath string, confPath string, topics []string) MQProducer