transport

type HandleFunc func(sessionID network.SessionID, messageID network.MessageID, payload []byte) ([]byte, error)

type Transport interface {
	// Push 发送消息，同步，阻塞，返回错误
	Push(topic string, sessionID network.SessionID, messageID network.MessageID, payload []byte) error

	// Request 发送消息，同步，阻塞，返回响应和错误
	Request(topic string, sessionID network.SessionID, messageID network.MessageID, payload []byte, timeout time.Duration) ([]byte, error)

	// SubscribeQueue 订阅消息。多个服务订阅同一个 topic 时，只有一个会获取到消息
	// 收到消息后，调用 handle 进行处理
	SubscribeQueue(topic string, handle HandleFunc) error

	// Subscribe 订阅消息。当多个服务器订阅同一个消息时，他们都会获取到消息
	// 收到消息后，调用 handle 进行处理
	Subscribe(topic string, handle HandleFunc)

	// Close 关闭
	Close() error
}