message

Jul 23, 2025

Changes in this version

type Message

+ func New(topic string, payload []byte) *Message

+ func (m *Message) GetCreateAt() time.Time

+ func (m *Message) GetDelay() time.Duration

+ func (m *Message) GetHeaders() map[string]string

+ func (m *Message) GetID() string

+ func (m *Message) GetPayload() []byte

+ func (m *Message) GetRetry() int

+ func (m *Message) GetTopic() string

+ func (m *Message) SetCreateAt(createAt time.Time) *Message

+ func (m *Message) SetDelay(delay time.Duration) *Message

+ func (m *Message) SetHeaders(headers map[string]string) *Message

+ func (m *Message) SetID(id string) *Message

+ func (m *Message) SetRetry(retry int) *Message

Jun 8, 2025

Changes in this version

+ type Handler func(ctx context.Context, msg *Message) error

type Message

+ CreateAt time.Time

+ Delay time.Duration

+ Headers map[string]string

+ ID string

+ Payload []byte

+ Retry int

+ Topic string

May 6, 2023

Changes in this version

type Message

+ func (message *Message) Key() string

Dec 22, 2021

Changes in this version

type Key

+ IsDelay bool

type Message

+ func (message *Message) IsDelay() bool

Sep 9, 2021

Changes in this version

+ type Key struct

+ ExchangeName string

+ QueueName string

+ RouteKey string

+ type Message struct

+ func NewMessage(key Key, id, body string) Message

+ func (message *Message) Body() string

+ func (message *Message) ExchangeName() string

+ func (message *Message) Id() string

+ func (message *Message) QueueName() string

+ func (message *Message) RouteKey() string