go-nsq

go-nsq copied to clipboard

add producerMgr pub with timeout func

3

add producerMgr pub with timeout func

qingfeng777

我看内部有 带timeout 的pub函数，为什么没有对外暴露呢？

2

内部带timeout 的 pub函数，好像只是用了 config里的timeout，没有在对外暴露的 Publish函数里提供timeout 参数。这是为什么呢，有什么考虑吗？ ` # producer.go line 1671 func (self *TopicProducerMgr) doCommandWithRetry(topic string, partitionKey []byte, commandFunc CmdFuncT) ([]byte, error) { return self.doCommandWithTimeoutAndRetry(topic, partitionKey, 0, 3, commandFunc) }...

qingfeng777

any plan to support `DeferredPublish`?

1

https://github.com/nsqio/go-nsq/blob/d71fb89c9e0263aaed89645b0b168e11ccf597b1/producer.go#L201

elvizlai