fix: generic pubsub

ochom · ochom · commit a47e2f2b693d · 2024-04-17T09:01:43.000+03:00
diff --git a/pubsub/publisher.go b/pubsub/publisher.go
@@ -52,11 +52,11 @@ func (p *publisher) publish(body []byte, delay time.Duration) error {
 }
 
 // PublishWithDelay ...
-func (p *publisher) PublishWithDelay(queueName string, body []byte, delay time.Duration) error {
+func (p *publisher) PublishWithDelay(body []byte, delay time.Duration) error {
 	return p.publish(body, delay)
 }
 
 // Publish ...
-func (p *publisher) Publish(queueName string, body []byte) error {
+func (p *publisher) Publish(body []byte) error {
 	return p.publish(body, 0)
 }

Original file line number	Diff line number	Diff line change
`@@ -52,11 +52,11 @@ func (p *publisher) publish(body []byte, delay time.Duration) error {`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`// PublishWithDelay ...`
`55`		`-func (p *publisher) PublishWithDelay(queueName string, body []byte, delay time.Duration) error {`
	`55`	`+func (p *publisher) PublishWithDelay(body []byte, delay time.Duration) error {`
`56`	`56`	`return p.publish(body, delay)`
`57`	`57`	`}`
`58`	`58`
`59`	`59`	`// Publish ...`
`60`		`-func (p *publisher) Publish(queueName string, body []byte) error {`
	`60`	`+func (p *publisher) Publish(body []byte) error {`
`61`	`61`	`return p.publish(body, 0)`
`62`	`62`	`}`