Skip to content

Commit 7063d28

Browse files
committed
fixed: producerCluster.atWithWrapper, producerCluster.delayWithWrapper bugs
1 parent ab6093a commit 7063d28

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

dq/producer.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -158,9 +158,13 @@ func (p *producerCluster) insert(fn func(node Producer) (string, error)) (string
158158
}
159159

160160
func (p *producerCluster) atWithWrapper(body []byte, at time.Time) (string, error) {
161-
return p.At(body, at)
161+
return p.insert(func(node Producer) (string, error) {
162+
return node.atWithWrapper(body, at)
163+
})
162164
}
163165

164166
func (p *producerCluster) delayWithWrapper(body []byte, delay time.Duration) (string, error) {
165-
return p.Delay(body, delay)
167+
return p.insert(func(node Producer) (string, error) {
168+
return node.delayWithWrapper(body, delay)
169+
})
166170
}

0 commit comments

Comments
 (0)