Versions in this module Expand all Collapse all v3 v3.0.7 Dec 19, 2022 v3.0.6 Dec 19, 2022 Changes in this version + type Manager struct + func NewManager(qstore Storage) *Manager + func (qm *Manager) Find(destination string) *Queue + type MemoryQueueStorage struct + func (m *MemoryQueueStorage) Dequeue(queue string) (*frame.Frame, error) + func (m *MemoryQueueStorage) Enqueue(queue string, frame *frame.Frame) error + func (m *MemoryQueueStorage) Requeue(queue string, frame *frame.Frame) error + func (m *MemoryQueueStorage) Start() + func (m *MemoryQueueStorage) Stop() + type Queue struct + func (q *Queue) Enqueue(f *frame.Frame) error + func (q *Queue) Requeue(f *frame.Frame) error + func (q *Queue) Subscribe(sub *client.Subscription) error + func (q *Queue) Unsubscribe(sub *client.Subscription) + type Storage interface + Dequeue func(queue string) (*frame.Frame, error) + Enqueue func(queue string, frame *frame.Frame) error + Requeue func(queue string, frame *frame.Frame) error + Start func() + Stop func() + func NewMemoryQueueStorage() Storage