model

Documentation

Index

• type Message
• type MessageHandle
• type QueueStorage

Types

type Message

type Message struct {
	Id           string
	Payload      json.RawMessage
	ConsumeCount int
	CreatedAt    time.Time
}

type MessageHandle

type MessageHandle interface {
	MessageHandler(Message) error
}

type QueueStorage

type QueueStorage interface {
	CreateChannel(string) error
	CreateDeadLetterQueue(string) error
	SaveDeadLetterQueue(queueName string, msg Message, errMsg string) error
	Save(string, []byte, string) error
	Read(int, int64, string, string) ([]Message, error)
	Close() error
}