Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemoryQueue ¶
type MemoryQueue struct {
Queue map[string]map[uint]chan gosignal.QueueMessage
}
func (*MemoryQueue) Subscribe ¶
func (mq *MemoryQueue) Subscribe(messageType string) (string, chan gosignal.QueueMessage, error)
func (*MemoryQueue) Unsubscribe ¶
func (mq *MemoryQueue) Unsubscribe(messageType, sid string) error
type MemoryQueueMessage ¶
type MemoryQueueMessage struct {
// contains filtered or unexported fields
}
func (MemoryQueueMessage) Ack ¶
func (MemoryQueueMessage) Ack() error
func (MemoryQueueMessage) Attempts ¶
func (MemoryQueueMessage) Attempts() int
func (MemoryQueueMessage) Message ¶
func (mqm MemoryQueueMessage) Message() []byte
func (MemoryQueueMessage) Nack ¶
func (MemoryQueueMessage) Nack() error
func (MemoryQueueMessage) Retry ¶
func (MemoryQueueMessage) Retry(gosignal.RetryParams) error
func (MemoryQueueMessage) Type ¶
func (mqm MemoryQueueMessage) Type() string
Source Files
Click to show internal directories.
Click to hide internal directories.