messageQueue

Mar 12, 2023

Changes in this version

+ type Consumer func(topic string, string string, message *Message) error

+ type ConsumerConfigure struct

+ Callback Consumer

+ Id string

+ Retry int

+ type MemoryMessageQueue struct

+ ConsumerErrorCallback Consumer

+ ConsumerSuccessCallback Consumer

+ Consumers map[string]*ConsumerConfigure

+ List *list.List

+ RunMode RunMode

+ Topic string

+ func NewMemoryMessageQueue(topic string, runMode RunMode) *MemoryMessageQueue

+ func (m *MemoryMessageQueue) AddConsumer(configure *ConsumerConfigure)

+ func (m *MemoryMessageQueue) CancelPause()

+ func (m *MemoryMessageQueue) GetConsumerCount() int

+ func (m *MemoryMessageQueue) Pause()

+ func (m *MemoryMessageQueue) Publish(message *Message) error

+ func (m *MemoryMessageQueue) RemoveConsumer(id string)

+ func (m *MemoryMessageQueue) SetConsumerErrorCallback(consumerErrorFunc Consumer)

+ func (m *MemoryMessageQueue) SetConsumerSuccessCallback(consumerSuccessFunc Consumer)

+ type Message struct

+ ConsumerId string

+ DisOrder bool

+ Id any

+ MessageEntry interface{}

+ type Publish struct

+ DisOrder bool

+ Message *Message

+ type RunMode uint8

+ const ModeChan

+ const ModeQueue