queue

Documentation

Index

• Variables
• func LoadAllQueues(db *bolt.DB, msgStore *msgstore.MessageStore, deleteChan chan *Queue) (map[string]*Queue, error)
• type Queue
  • func NewFromPersistedState(state *gen.QueueState, msgStore *msgstore.MessageStore, deleteChan chan *Queue) *Queue
  • func NewQueue(name string, durable bool, exclusive bool, autoDelete bool, ...) *Queue
  • func (q *Queue) ActiveConsumerCount() uint32
  • func (q *Queue) Add(qm *amqp.QueueMessage) bool
  • func (q *Queue) AddConsumer(c *consumer.Consumer, exclusive bool) (uint16, error)
  • func (q *Queue) Close()
  • func (q *Queue) ConsumeImmediate(qm *amqp.QueueMessage) bool
  • func (q *Queue) Delete(ifUnused bool, ifEmpty bool) (uint32, error)
  • func (q *Queue) Depersist(db *bolt.DB) error
  • func (q *Queue) DepersistBoltTx(tx *bolt.Tx) error
  • func (q1 *Queue) EquivalentQueues(q2 *Queue) bool
  • func (q *Queue) GetOne(rhs ...amqp.MessageResourceHolder) (*amqp.QueueMessage, *amqp.Message)
  • func (q *Queue) GetOneForced() *amqp.QueueMessage
  • func (q *Queue) Len() uint32
  • func (q *Queue) LoadFromMsgStore(msgStore *msgstore.MessageStore)
  • func (q *Queue) MarshalJSON() ([]byte, error)
  • func (q *Queue) MaybeReady() chan bool
  • func (q *Queue) Persist(db *bolt.DB) error
  • func (q *Queue) Purge() uint32
  • func (q *Queue) Readd(queueName string, msg *amqp.QueueMessage)
  • func (q *Queue) Start()
• type QueueStateFactory
  • func (qsf *QueueStateFactory) New() proto.Unmarshaler

Variables

var QUEUE_BUCKET_NAME = []byte("queues")

Functions

func LoadAllQueues

func LoadAllQueues(db *bolt.DB, msgStore *msgstore.MessageStore, deleteChan chan *Queue) (map[string]*Queue, error)

Types

type Queue

type Queue struct {
	gen.QueueState

	Closed bool

	ConnId int64
	// contains filtered or unexported fields
}

func NewFromPersistedState

func NewFromPersistedState(state *gen.QueueState, msgStore *msgstore.MessageStore, deleteChan chan *Queue) *Queue

func NewQueue

func NewQueue(
	name string,
	durable bool,
	exclusive bool,
	autoDelete bool,
	arguments *amqp.Table,
	connId int64,
	msgStore *msgstore.MessageStore,
	deleteChan chan *Queue,
) *Queue

func (*Queue) ActiveConsumerCount

func (q *Queue) ActiveConsumerCount() uint32

func (*Queue) Add

func (q *Queue) Add(qm *amqp.QueueMessage) bool

func (*Queue) AddConsumer

func (q *Queue) AddConsumer(c *consumer.Consumer, exclusive bool) (uint16, error)

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) ConsumeImmediate

func (q *Queue) ConsumeImmediate(qm *amqp.QueueMessage) bool

func (*Queue) Delete

func (q *Queue) Delete(ifUnused bool, ifEmpty bool) (uint32, error)

func (*Queue) Depersist

func (q *Queue) Depersist(db *bolt.DB) error

func (*Queue) DepersistBoltTx

func (q *Queue) DepersistBoltTx(tx *bolt.Tx) error

func (*Queue) EquivalentQueues

func (q1 *Queue) EquivalentQueues(q2 *Queue) bool

func (*Queue) GetOne

func (q *Queue) GetOne(rhs ...amqp.MessageResourceHolder) (*amqp.QueueMessage, *amqp.Message)

func (*Queue) GetOneForced

func (q *Queue) GetOneForced() *amqp.QueueMessage

func (*Queue) Len

func (q *Queue) Len() uint32

func (*Queue) LoadFromMsgStore

func (q *Queue) LoadFromMsgStore(msgStore *msgstore.MessageStore)

func (*Queue) MarshalJSON

func (q *Queue) MarshalJSON() ([]byte, error)

func (*Queue) MaybeReady

func (q *Queue) MaybeReady() chan bool

func (*Queue) Persist

func (q *Queue) Persist(db *bolt.DB) error

func (*Queue) Purge

func (q *Queue) Purge() uint32

func (*Queue) Readd

func (q *Queue) Readd(queueName string, msg *amqp.QueueMessage)

func (*Queue) Start

func (q *Queue) Start()

type QueueStateFactory

type QueueStateFactory struct{}

func (*QueueStateFactory) New

func (qsf *QueueStateFactory) New() proto.Unmarshaler