Documentation ¶
Index ¶
- type Consumer
- type ConsumerConfigure
- type 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
- type Publish
- type RunMode
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerConfigure ¶
type MemoryMessageQueue ¶
type MemoryMessageQueue struct { RunMode RunMode Topic string List *list.List Consumers map[string]*ConsumerConfigure ConsumerErrorCallback Consumer ConsumerSuccessCallback Consumer // contains filtered or unexported fields }
func NewMemoryMessageQueue ¶
func NewMemoryMessageQueue(topic string, runMode RunMode) *MemoryMessageQueue
func (*MemoryMessageQueue) AddConsumer ¶
func (m *MemoryMessageQueue) AddConsumer(configure *ConsumerConfigure)
func (*MemoryMessageQueue) CancelPause ¶
func (m *MemoryMessageQueue) CancelPause()
CancelPause resume
func (*MemoryMessageQueue) GetConsumerCount ¶
func (m *MemoryMessageQueue) GetConsumerCount() int
func (*MemoryMessageQueue) Pause ¶
func (m *MemoryMessageQueue) Pause()
func (*MemoryMessageQueue) Publish ¶
func (m *MemoryMessageQueue) Publish(message *Message) error
func (*MemoryMessageQueue) RemoveConsumer ¶
func (m *MemoryMessageQueue) RemoveConsumer(id string)
func (*MemoryMessageQueue) SetConsumerErrorCallback ¶
func (m *MemoryMessageQueue) SetConsumerErrorCallback(consumerErrorFunc Consumer)
func (*MemoryMessageQueue) SetConsumerSuccessCallback ¶
func (m *MemoryMessageQueue) SetConsumerSuccessCallback(consumerSuccessFunc Consumer)
Click to show internal directories.
Click to hide internal directories.