message

Documentation

Overview

Package message 存放消息队列相关代码

Index

• Constants
• type Base
  • func (b *Base) Consume(topic, channel string)
  • func (b *Base) Produce(topic string, body []byte) error
  • func (b *Base) Publish(topic string, body []byte) error
  • func (b *Base) Subscribe(topic, channel string)

Constants

const (
	TopicOne = "One"
)

主题定义

Types

type Base

type Base struct {
}

Base 基底

func (*Base) Consume

func (b *Base) Consume(topic, channel string)

Consume 消费

func (*Base) Produce

func (b *Base) Produce(topic string, body []byte) error

Produce 生产

func (*Base) Publish

func (b *Base) Publish(topic string, body []byte) error

Publish 发布

func (*Base) Subscribe

func (b *Base) Subscribe(topic, channel string)

Subscribe 订阅