delay

package

v1.6.2 Latest Latest Go to latest Published: Apr 20, 2022 License: MIT Imports: 4 Imported by: 0

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

This section is empty.

This section is empty.

This section is empty.

type Consumer struct {
	// contains filtered or unexported fields
}

func NewDelayConsumer(url, exchangeName, queueName string, chanNumber int) (*Consumer, error)

func (c *Consumer) Declare()

Declare 队列绑定

func (c *Consumer) Destroy()

Destroy 关闭连接

func (c *Consumer) OnConnectionErrorReConnection()

OnConnectionErrorReConnection 连接错误，自动重连

func (c *Consumer) Received(autoAck bool, handler func(receiveData, objectType string) error)

Received 通过回调函数处理接收到的消息

type Producer struct {
	// contains filtered or unexported fields
}

func NewDelayProducer(url, exchangeName, queueName string) (*Producer, error)

NewDelayProducer 创建一个新的 Producer 实例

func (p *Producer) Close()

Close 手动关闭连接

func (p *Producer) OnConnectionErrorReConnection()

OnConnectionErrorReConnection 监听连接错误，自动重连

func (p *Producer) Send(data, routeKey, delay, objectType string) error

Send 发送数据，channel 复用