queue

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