mq

package module
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 6, 2023 License: MIT Imports: 5 Imported by: 0

README

go-mq

基于amqp的消息队列

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewQueueConsumer added in v0.0.4 

func NewQueueConsumer(driver Driver, queueKey string, config contract.Config) (contract.Consumer, error)

NewQueueConsumer 队列消费者

func NewQueueProducer added in v0.0.4 

func NewQueueProducer(driver Driver, config contract.Config) (contract.Producer, error)

NewQueueProducer 队列生产者

Types

type Driver 

type Driver string
const (
	Amqp  Driver = "amqp"
	Redis Driver = "redis"
)

Source Files

View all Source files

Directories

Path Synopsis
driver
amqp
redis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.