queue

Feb 18, 2024

Changes in this version

+ type MemoryQueue struct

+ Queue map[string]map[uint]chan gosignal.QueueMessage

+ func (mq *MemoryQueue) Send(messageType string, message []byte) error

+ func (mq *MemoryQueue) Subscribe(messageType string) (string, chan gosignal.QueueMessage, error)

+ func (mq *MemoryQueue) Unsubscribe(messageType, sid string) error

+ type MemoryQueueMessage struct

+ func (MemoryQueueMessage) Ack() error

+ func (MemoryQueueMessage) Attempts() int

+ func (MemoryQueueMessage) Nack() error

+ func (MemoryQueueMessage) Retry(gosignal.RetryParams) error

+ func (mqm MemoryQueueMessage) Message() []byte

+ func (mqm MemoryQueueMessage) Type() string