queue

package
v0.0.0-...-b242329 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2019 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL