callbak开放出来

[MisterChing]

1.希望 callback处理函数增加 WithCallback 开放出来
2.希望能增加队列阻塞监控

感谢~

[HDT3213]

抱歉，没看到这个 issue

队列阻塞这个我看看整个 opentelemetry 进去。
请问暴露 callback 是为了做什么呢

[ggdream]

@HDT3213 你好，我也认为考虑暴露callback，并且单独抽出生产者和消费者。我的理由是目前设计没有很好的解耦，想实现业务里投递Job消费的场景

[HDT3213]

@ggdream 生产者已经独立出来了。 分开部署生产者和消费者

我不太明白暴露 callback 是什么意思？是指可以随时设置 callback 吗？

[MisterChing]

@ggdream 生产者已经独立出来了。 分开部署生产者和消费者

我不太明白暴露 callback 是什么意思？是指可以随时设置 callback 吗？

嗯，目前处理函数只能在启动的时候注册进去，希望能在配置实例对象时注册

[HDT3213]

@MisterChing v1.0.5 中加了一个 WithCallback

queue := NewQueue("test", redisCli)
queue.WithCallback(func(payload string) bool {
	return true
})

[ggdream]

@HDT3213 好的，辛苦

[HDT3213]

@MisterChing 忘记说了，队列阻塞监控也有了， 监控

monitor := delayqueue.NewMonitor("example", redisCli)
blocked, err := monitor.GetReadyCount()

[MisterChing]

@MisterChing 忘记说了，队列阻塞监控也有了， 监控

monitor := delayqueue.NewMonitor("example", redisCli)
blocked, err := monitor.GetReadyCount()

赞，辛苦