rmq

type AsyncSendHandler = func(context.Context, []*SendReceipt, error)

type Consumer interface {
	Start() error
	Receive() ([]*MessageView, error)
	ReceiveWithContext(ctx context.Context) ([]*MessageView, error)
	GetSimpleConsumer() SimpleConsumer
	Ack(ctx context.Context, messageView *MessageView) error
	Close() error
}

type ConsumerConfig struct {
	Topic                   string
	Group                   string
	Endpoint                string
	AccessKey               string
	SecretKey               string
	SubscriptionExpressions map[string]*FilterExpression
	AwaitDuration           time.Duration // maximum waiting time for receive func
	MaxMessageNum           int32         // maximum number of messages received at one time
	InvisibleDuration       time.Duration // invisibleDuration should > 20s
	// StartTimeout Start() 方法的超时时间
	// 如果为 0，则使用默认值 DefaultConsumerStartTimeout (10秒)
	// 注意：这是应用层的超时控制，用于防止 Start() 方法无限阻塞
	// 官方 SDK 的 Start() 方法本身没有内置超时机制
	// 建议设置为 10-30 秒，避免启动时长时间阻塞
	StartTimeout time.Duration
}

type ErrRpcStatus = rmqClient.ErrRpcStatus

type FilterExpression = rmqClient.FilterExpression

type Message = rmqClient.Message

type MessageView = rmqClient.MessageView

type MessageViewFunc func(*MessageView) bool

type Producer interface {
	Start() error
	Close() error
	GetProducer() RProducer
	// SendNormalMessage 同步发送普通消息（阻塞方法）
	// 注意：此方法会阻塞等待服务器响应，建议使用 context 设置超时时间
	// 如果需要非阻塞发送，请使用 AsyncSendNormalMessage
	SendNormalMessage(context.Context, *Message) ([]*SendReceipt, error)
	// AsyncSendNormalMessage 异步发送普通消息（非阻塞方法）
	// handler: 发送完成后的回调函数
	AsyncSendNormalMessage(context.Context, *Message, AsyncSendHandler)
	// SendFifoMessage 同步发送顺序消息（阻塞方法）
	// 注意：此方法会阻塞等待服务器响应，建议使用 context 设置超时时间
	SendFifoMessage(context.Context, *Message) ([]*SendReceipt, error)
	// SendDelayMessage 同步发送延时消息（阻塞方法）
	// 注意：此方法会阻塞等待服务器响应，建议使用 context 设置超时时间
	SendDelayMessage(context.Context, *Message, time.Time) ([]*SendReceipt, error)
}

type ProducerConfig struct {
	//Topic     string
	Endpoint  string
	AccessKey string
	SecretKey string
	// StartTimeout Start() 方法的超时时间
	// 如果为 0，则使用默认值 DefaultProducerStartTimeout (30秒)
	// 注意：这是应用层的超时控制，用于防止 Start() 方法无限阻塞
	// 官方 SDK 的 Start() 方法本身没有内置超时机制
	// 如果遇到连接问题，建议设置为 30-60 秒
	StartTimeout time.Duration
	// DialTimeout gRPC 连接建立的超时时间
	// 如果为 0，则使用默认值 DefaultDialTimeout (20秒)
	// 注意：这是 SDK 层面的连接超时，用于控制 gRPC Dial 操作的超时
	// 如果遇到连接问题，建议设置为 20-30 秒，应该小于或等于 StartTimeout
	DialTimeout time.Duration
	// MaxAttempts 消息发送的最大重试次数（默认 SDK 为 3）
	// 注意：此参数只用于消息发送重试，不用于 Start() 连接过程
	// Start() 的连接过程没有最大尝试次数限制，会无限重试
	// 因此仍需要 StartTimeout 来控制 Start() 的超时
	MaxAttempts int32
}

type RProducer = rmqClient.Producer

type SendReceipt = rmqClient.SendReceipt

type SimpleConsumer = rmqClient.SimpleConsumer