SpringMessage

Documentation

Index

• type Consumer
• type Message
• type Producer

Types

type Consumer

type Consumer interface {
	Consume(msg *Message)
}

消息消费者

type Message

type Message struct {
	Topic      string
	Key        string
	Value      []byte
	Properties map[string]string
}

type Producer

type Producer interface {
	Send(topic string, body string) error
}

消息生产者