queue

Documentation

Index

• Constants
• func PublishExample(ctx context.Context, msg *message.ExampleMsg) error
• func SubscribeExample(ctx context.Context, ...) error

Constants

const (
	ExampleTopic = "example" // 示例消息队列topic
)

Functions

func PublishExample

func PublishExample(ctx context.Context, msg *message.ExampleMsg) error

PublishExample 发布示例消息

func SubscribeExample

func SubscribeExample(ctx context.Context, fn func(ctx context.Context, msg *message.ExampleMsg) error) error

SubscribeExample 订阅示例消息