exchange

type Event int

type Exchange interface {
	Push(message Message)           // 将消息推送到交换器
	Receive(consume MessageConsume) // 从交换器接收消息
	Start(ctx context.Context)      // 启动
	Stop()                          // 停止消息接收
}

type Fields map[string]interface{} // 维护动态字段

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

type Message struct {
	AppID          string `json:"app_id,required"`          // 应用ID
	From           string `json:"from,required"`            //发送者ID
	To             string `json:"to,required"`              //接收者ID
	Event          Event  `json:"event,required"`           //事件类型
	Data           Fields `json:"data,required"`            //消息内容
	MsgID          string `json:"msg_id,required"`          //消息ID
	SendAt         int64  `json:"send_at,required"`         //发送时间
	ConversationID string `json:"conversation_id,required"` //会话ID
}

type MessageConsume func(message Message)

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

type RedisConn struct {
	Uri       string // redis地址
	QueueName string
	Conn      *redis.Client
	Ch        *redis.PubSub
}

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

type Session struct {
	ExchangeName string
	QueueName    string
	ExchangeType string
	Conn         *amqp.Connection
	Ch           *amqp.Channel

	Uri string
	// contains filtered or unexported fields
}