queue

package

v0.10.0 Latest Latest Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 6 Imported by: 0

Details

View Source

const (
	// QName is machinery task queue
	QName = "machinery_tasks"
)

This section is empty.

This section is empty.

type Connector struct {
	Server *machinery.Server
	// contains filtered or unexported fields
}

Connector is used to connect to the queue

func NewQueueConnector(dialer string) *Connector

NewQueueConnector creates a new queue connector

func (qc *Connector) StartWorker()

StartWorker - starts worker to process registered tasks

func (qc *Connector) StopWorker()

StopWorker stops the worker and prevents it from consuming more tasks.