rabbitmq

type AmqpConfig struct {
	DsName   string
	Host     string
	Port     int
	Username string
	Password string
}

type AmqpManager struct {
	DsName string
	// contains filtered or unexported fields
}

type DLX struct {
	DlxExchange string                                 // 死信交换机
	DlxQueue    string                                 // 死信队列
	DlkExchange string                                 // 重读交换机
	DlkQueue    string                                 // 重读队列
	DlkCallFunc func(message MsgData) (MsgData, error) // 回调函数
}

type LisData struct {
	Exchange      string
	Queue         string
	Kind          string
	PrefetchCount int
	PrefetchSize  int
	SendMgo       bool
	IsNack        bool
}

type MQErrorLog struct {
	Id       int64       `json:"id" bson:"_id" tb:"mq_error_log" mg:"true"`
	Exchange string      `json:"exchange" bson:"exchange"`
	Queue    string      `json:"queue" bson:"queue"`
	Content  interface{} `json:"content" bson:"content"`
	Type     int64       `json:"type" bson:"type"`
	Delay    int64       `json:"delay" bson:"delay"`
	Retries  int64       `json:"retries" bson:"retries"`
	Error    string      `json:"error" bson:"error"`
	Ctime    int64       `json:"ctime" bson:"ctime"`
	Utime    int64       `json:"utime" bson:"utime"`
	State    int64       `json:"state" bson:"state"`
}

type MsgData struct {
	Exchange  string      `json:"exchange"`
	Queue     string      `json:"queue"`
	Kind      string      `json:"kind"`
	Content   interface{} `json:"content"`
	Type      int64       `json:"type"`
	Delay     int64       `json:"delay"`
	Retries   int64       `json:"retries"`
	Signature string      `json:"signature"`
}

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

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

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

type PullReceiver struct {
	Exchange string
	Queue    string
	LisData  LisData
	Callback func(msg MsgData) (MsgData, error)
	// contains filtered or unexported fields
}