Documentation
¶
Index ¶
- func GetMqProducer(ctx context.Context) (mqProducer golang.Producer, err error)
- func GetMqPushConsumer(ctx context.Context) (simpleConsumer golang.SimpleConsumer, err error)
- func GetMqSimpleConsumer(ctx context.Context) (simpleConsumer golang.SimpleConsumer, err error)
- func InitDefaultSimpleConsumer(ctx context.Context, fn func(m *golang.MessageView) error)
- func InitMQ(ctx context.Context)
- func InitMQConfig(ctx context.Context)
- func SendDefaultMessage(ctx context.Context, tag string, key string, data []byte) (bool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMqProducer ¶
func GetMqPushConsumer ¶
func GetMqPushConsumer(ctx context.Context) (simpleConsumer golang.SimpleConsumer, err error)
func GetMqSimpleConsumer ¶
func GetMqSimpleConsumer(ctx context.Context) (simpleConsumer golang.SimpleConsumer, err error)
func InitDefaultSimpleConsumer ¶
func InitDefaultSimpleConsumer(ctx context.Context, fn func(m *golang.MessageView) error)
func InitMQConfig ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.