Versions in this module Expand all Collapse all v1 v1.0.1 Aug 23, 2014 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) (*stomp.Frame, error) + func (m *MemoryQueueStorage) Enqueue(queue string, frame *stomp.Frame) error + func (m *MemoryQueueStorage) Requeue(queue string, frame *stomp.Frame) error + func (m *MemoryQueueStorage) Start() + func (m *MemoryQueueStorage) Stop() + type Queue struct + func (q *Queue) Enqueue(f *stomp.Frame) error + func (q *Queue) Requeue(f *stomp.Frame) error + func (q *Queue) Subscribe(sub *client.Subscription) error + func (q *Queue) Unsubscribe(sub *client.Subscription) + type Storage interface + Dequeue func(queue string) (*stomp.Frame, error) + Enqueue func(queue string, frame *stomp.Frame) error + Requeue func(queue string, frame *stomp.Frame) error + Start func() + Stop func() + func NewMemoryQueueStorage() Storage Incompatible versions in this module v2.0.0+incompatible Nov 4, 2016
Go to main page