queue

type Message struct {
	IgnoreAccountId string         `json:"ignoreAccountId"`
	KeyId           string         `json:"keyId"`
	Payload         []byte         `json:"payload"`
	Signature       []byte         `json:"signature"`
	Topics          []domain.Topic `json:"topics"`
	Created         time.Time      `json:"created"`
	GroupId         string         `json:"groupId"`
	Silent          bool           `json:"silent"`
}

type Queue interface {
	Add(ctx context.Context, msg Message) error
	Consume(ctx context.Context, handle func(msg Message) error) error
	app.ComponentRunnable
}