mq

package

v1.1.3 Latest Latest Go to latest Published: Oct 9, 2022 License: Apache-2.0 Imports: 5 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package mq 提供了标准的消息队列接口，可以灵活适配各种 MQ 实现。

This section is empty.

This section is empty.

func Bind(fn interface{}, topics ...string) *consumer

Bind 创建 Bind 方式的消费者。

func NewMessage() *message

NewMessage 创建新的消息对象。

type Consumer interface {
	Topics() []string
	Consume(ctx context.Context, msg Message) error
}

Consumer 消息消费者。

type Message interface {
	Topic() string
	ID() string
	Body() []byte
	Extra() map[string]string
}

type Producer interface {

	// SendMessage 传入的消息类型不同用途也不同，需要分别判断。
	SendMessage(ctx context.Context, msg Message) error
}

Producer 消息生产者。