Skip to content

github.com/RichardKnop/machinery/v2 driver for Queue

Notifications You must be signed in to change notification settings

goravel/machinery

Repository files navigation

machinery

A machinery queue driver for facades.Queue() of Goravel. Will deprecated and removed in v1.17.

Version

goravel/machinery goravel/framework
v1.0.* v1.16.*

Install

  1. Add package
go get -u github.com/goravel/machinery
  1. Register service provider
// config/app.go
import "github.com/goravel/machinery"

"providers": []foundation.ServiceProvider{
    ...
    // Need register machinery service provider before queue service provider
    &machinery.ServiceProvider{},
   // Exists in the config/app.go file, DO NOT copy this line
    &queue.ServiceProvider{},
    ...
}
  1. Add your machinery configuration to config/queue.go file
import (
    "github.com/goravel/framework/contracts/queue"
    machineryfacades "github.com/goravel/machinery/facades"
)

"connections": map[string]any{
    ...
    "machinery": map[string]any{
        "driver": "custom",
        "connection": "default",
        "queue": "default",
        "via": func() (queue.Driver, error) {
            return machineryfacades.Machinery("machinery"), nil // The `machinery` value is the key of `connections`
        },
    },
},
  1. Fill redis configuration to config/database.go file
// config/database.go
"redis": map[string]any{
    "default": map[string]any{
        "host":     config.Env("REDIS_HOST", ""),
        "password": config.Env("REDIS_PASSWORD", ""),
        "port":     config.Env("REDIS_PORT", 6379),
        "database": config.Env("REDIS_DB", 0),
    },
},

About

github.com/RichardKnop/machinery/v2 driver for Queue

Resources

Stars

Watchers

Forks

Releases

No releases published

Languages