Documentation ¶
Index ¶
- Variables
- type Options
- type RabbitMQ
- func (r *RabbitMQ) Close() error
- func (r *RabbitMQ) CreateQueue(ctx context.Context, key string) error
- func (r *RabbitMQ) DeclareConsume(key string) error
- func (r *RabbitMQ) Destroy(ctx context.Context, key string) error
- func (r *RabbitMQ) Pop(ctx context.Context, key string) <-chan string
- func (r *RabbitMQ) Push(ctx context.Context, key, data string) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Client = NewRabbitMQ(options)
Client 测试案例使用的客户端,请自定义
Functions ¶
This section is empty.
Types ¶
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
RabbitMQ rabbitMQ结构体
func (*RabbitMQ) CreateQueue ¶
CreateQueue 创建队列
func (*RabbitMQ) DeclareConsume ¶
Click to show internal directories.
Click to hide internal directories.