rabbitmq

package

v0.3.4 Latest Latest Go to latest Published: Mar 11, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	URL          string
	Exchange     string
	ExchangeType string
	Durable      bool
	AutoDelete   bool
	Prefetch     int
}

type Queue struct {
	// contains filtered or unexported fields
}

func New(config Config) *Queue

func (q *Queue) Dispose() error

func (q *Queue) ImplName() scene.ImplName

func (q *Queue) Publish(ctx context.Context, task *asynctask.QueueTask) (*asynctask.QueueTask, error)

func (q *Queue) RegisterHandler(queue string, taskType string, handler asynctask.TaskQueueHandler) error

func (q *Queue) RegisterQueue(queue string, config asynctask.TaskQueueConfig) error

func (q *Queue) Setup() error