mpmq

Documentation

Overview

Package mpmq base User: 姜伟 Time: 2020-02-19 06:40:35

Package mpmq constant User: 姜伟 Time: 2020-02-19 06:40:53

Package mpmq consumer User: 姜伟 Time: 2020-02-19 06:41:32

Package mpmq consumer_rabbit User: 姜伟 Time: 2020-02-19 06:41:06

Package mpmq consumer_redis User: 姜伟 Time: 2020-02-19 06:41:20

Package mpmq producer User: 姜伟 Time: 2020-02-19 06:42:40

Package mpmq producer_rabbit User: 姜伟 Time: 2020-02-19 06:42:02

Package mpmq producer_redis User: 姜伟 Time: 2020-02-19 06:42:18

Index

• func NewConsumer() *consumerMQ
• func NewProducer() *producerMQ
• type IConsumer
• type IProducer

Functions

func NewConsumer

func NewConsumer() *consumerMQ

NewConsumer NewConsumer

func NewProducer

func NewProducer() *producerMQ

NewProducer NewProducer

Types

type IConsumer

type IConsumer interface {
	PullData(topic string) (interface{}, error)
	Shutdown() int
}

IConsumer IConsumer

type IProducer

type IProducer interface {
	SendTopicData(topic string, data []string) int
}

IProducer IProducer