dynaqueue

Documentation

Index

• type Queues
  • func NewQueue(systemName string, ec *nats.EncodedConn, recvChan chan *transport.Message, ...) *Queues
  • func (q *Queues) Add(name string)
  • func (q *Queues) Pop(name string) *queueItem
  • func (q *Queues) Start(name string)
  • func (q *Queues) StartAll() error

Types

type Queues

type Queues struct {
	System string
	*nats.EncodedConn
	Queues map[string]*queueItem
	*sync.Mutex
	MessageQueue chan *transport.Message
	// contains filtered or unexported fields
}

the app add and use differrent nats queues..

func NewQueue

func NewQueue(systemName string, ec *nats.EncodedConn, recvChan chan *transport.Message, logger hclog.Logger) *Queues

func (*Queues) Add

func (q *Queues) Add(name string)

func (*Queues) Pop

func (q *Queues) Pop(name string) *queueItem

func (*Queues) Start

func (q *Queues) Start(name string)

func (*Queues) StartAll

func (q *Queues) StartAll() error