TaskQueue

Documentation

Index

• func CreateQueue(ch *amqp.Channel, queueName string) (err error)
• func CreateTaskToAnalyzeCatalog(ch *amqp.Channel, catalogID int64) (err error)
• func CreateTaskToAnalyzeFile(ch *amqp.Channel, fileID int64) (err error)
• func QueueTask(ch *amqp.Channel, channelName string, msg []byte) error

Functions

func CreateQueue

func CreateQueue(ch *amqp.Channel, queueName string) (err error)

CreateQueue declares durable queues

func CreateTaskToAnalyzeCatalog

func CreateTaskToAnalyzeCatalog(ch *amqp.Channel, catalogID int64) (err error)

CreateTaskToAnalyzeCatalog creates a rabbitMQ task for a worker to pick up

func CreateTaskToAnalyzeFile

func CreateTaskToAnalyzeFile(ch *amqp.Channel, fileID int64) (err error)

CreateTaskToAnalyzeFile creates a rabbitMQ task for a worker to pick up

func QueueTask

func QueueTask(ch *amqp.Channel, channelName string, msg []byte) error

QueueTask sends the message to the queueing server