producer

type AMQP struct {
	Online bool //是否在线
	// contains filtered or unexported fields
}

type MqProducer interface {
	// Publish 发送消息，有错误就返回,发送成功error为nil
	Publish(PMessage, PRoute) error
	// DelayPublish 延迟发送消息，有错误就返回,发送成功error为nil
	DelayPublish(time.Duration, PMessage, PRoute) error
	Close()
}

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

type Option func(opt *Poptions)

type PMessage struct {
	Time time.Time //kafka 指定消息发送的时间
	Key  string    //kafka消息有key，如果是其他mq没有key则不用填写
	Body []byte    //消息内容
}

type PRoute struct {
	Exchange  string                 //AMQP
	RouteKey  string                 //AMQP
	QueueName string                 //AMQP
	Args      map[string]interface{} //AMQP
	Topic     string                 //kafka topic, nsq topic
}

type Poptions struct {
	Vhost            string        //AMQP
	Timeout          time.Duration //秒,0不超时
	Username         string
	Password         string
	AuthSecret       string
	AMQPQueueDeclare mq.AMQPQueueDeclareOPT
	AMQPPulish       mq.AMQPPubiishOPT
	AMQPQueueBind    mq.AMQPQueueBindOPT
	GenQueueExpires  int //amq.gen--XXXXXX 自动清除时间 ms
	PRoute           PRoute
}