message

Documentation

Index

• type Extra
• type Handler

Types

type Extra

type Extra struct {
	Attributes map[string]string
	Messages   map[string]types.MessageAttributeValue
	Id         *string
	Handle     *string
}

type Handler

type Handler[T any] interface {
	// Peek 取出一个新的消息
	Peek() T

	// Process 处理消息
	Process(ctx *kernel.Context, msg T, extra *Extra) error
}