README ¶ go-mq 基于amqp的消息队列 Expand ▾ Collapse ▴ Documentation ¶ Index ¶ func NewQueueConsumer(driver Driver, queueKey string, config contract.Config) (contract.Consumer, error) func NewQueueProducer(driver Driver, queueKey string, config contract.Config) (contract.Producer, error) type Driver 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, queueKey string, config contract.Config) (contract.Producer, error) NewQueueProducer 队列生产者 Types ¶ type Driver ¶ type Driver string const ( Amqp Driver = "amqp" ) Source Files ¶ View all Source files queue.go Directories ¶ Show internal Expand all Path Synopsis contract driver amqp message Click to show internal directories. Click to hide internal directories.