syncmq

type Hooker interface {
	HandleMqMessage(ctx *context.BizContext, message *TopicMessage) error
}

type MqConsumerServer struct {
	Ctx      *context.BaseContext
	Kind     string
	Topics   []string
	Cluster  string
	ConfPath string
	LogPath  string
	Group    string
	// contains filtered or unexported fields
}

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

type TopicMessage struct {
	TopicName string
	Message   string
}