event

type Message struct {
	ID              uuid.UUID
	Name            string
	Payload         json.RawMessage
	CreatedAt       time.Time
	ProcessedAt     *time.Time
	RetryCount      int
	LastError       *string
	ProcessingSince time.Time
}

type MessageHandler func(context.Context, Message) error