esb

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

type DuplexMessage struct {
	Message
	// 发送方应答队列
	Source string
	// 接受方请求队列
	DestinationNew string
	// 接收方应答队列
	DestinationAck string
}

type Message struct {
	Body *MsgBody
	// contains filtered or unexported fields
}

type MessageListener interface {
	// OnReceived 接收消息`msg`并进行处理，如果处理失败则抛出异常。如果需要返回消息（如事务消息需要返回）请返回消息体内容，否则请返回nil。
	OnReceived(msg interface{}) (*MsgBody, error)

	// OnRecipientAckReceived 处理接收方发出的ACK消息，由消息发送方处理。在双向事务消息中消息发送方还应该在处理完成后返回一个应答消息通知接收方处理结果`rsp`。如果返回结果为nil则不发送。
	OnRecipientAckReceived(genre, msgId string, rsp *MsgBody) (*MsgBody, error)

	// OnSenderAckReceived 处理发送方发出的ACK消息，由接收方处理，该方法仅在双向事务消息中有效，通知接收方最终发送方的处理结果`rsp`。
	OnSenderAckReceived(genre, msgId string, rsp *MsgBody) error
}

type MsgBody struct {
	Body map[string]string `json:"body"`
}

type MsgPayload struct {
	Category    _MessageCategory `json:"category"`    // 消息分类
	Genre       string           `json:"type"`        // 消息类型
	MsgId       string           `json:"msgId"`       // 消息的唯一ID，发送时自动生成
	SrcAckQueue string           `json:"srcAckQueue"` // 消息发送方的应答队列名称（对事务消息有效）
	DstNewQueue string           `json:"dstNewQueue"` // 消息接收方的新消息队列名称
	DstAckQueue string           `json:"dstAckQueue"` // 消息接收方的应答消息队列（对双向事务消息有效）
	Body        *MsgBody         `json:"body"`        // 业务数据
	SendTime    int64            `json:"sendTime"`    // 发送时间
	Phase       _MessagePhase    `json:"phase"`       // 消息所处的阶段
	Sign        string           `json:"sign"`        // 签名信息
}

type Node int64

type NoticeMessage struct {
	Message
	Destination string
}

type Option func(*options)

type Processor interface {
	// GetType 获取要处理的消息类型，对应{Message}中的type字段。
	GetType() string

	// OnReceived 接收新消息并进行处理，如果新消息为事务消息并且需要返回处理结果则请返回处理结果，否则返回Null即可。
	OnReceived(msg interface{}) (*MsgBody, error)

	// OnRecipientAckReceived 单向/双向事务消息中的接收方应答消息的接收处理，对于单向事务消息处理完成后返回Null即可，对于双向事务消息则还需要返回系统的处理结果给到接收方进行后续处理。
	OnRecipientAckReceived(msgId string, rsp *MsgBody) (*MsgBody, error)

	// OnSenderAckReceived 双向事务消息中的发送方的确认应答消息(msgId:事务消息的唯一ID)，由接收方进行处理发送方返回的应答消息`rsp`。
	OnSenderAckReceived(msgId string, rsp *MsgBody) error
}

type Provider interface {
	// Listen 监听指定名称`name`的消息队列，当有新消息或事务应答消息送达时会调用监听器`listener`接口并返回关闭动作`closer`，可同时监听多个不同的队列。
	// 特别注意：同一个消息队列只能有一个监听器！
	Listen(name string, listener MessageListener) (closer func(), err error)

	// Cancel 取消对指定队列名称`name`的监听。
	Cancel(name string)

	// Send 发送ESB消息
	Send(message interface{}) error

	// Close 关闭到消息中间件的连接，清除资源。
	Close()
}

type SimplexMessage struct {
	Message
	Source      string
	Destination string
}