Documentation
¶
Overview ¶
Package queue provides different queue handlers (implementations for AMQ Queues)
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPQHandler ¶
func NewPQHandler() amq.QueueHandler
func NewQueueHandler ¶
func NewQueueHandler() amq.QueueHandler
NewQueueHandler returns default in-memory message queue implementation.
Default implementation is not goroutine-safe, concurrent access is controlled inside high-level Queue type.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.