dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Small naming fixes 

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
This commit is contained in:
ItalyPaleAle 2022-12-19 22:03:53 +00:00
parent 64cd81e372
commit fc00023206
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pubsub/azure/servicebus/queues/servicebus.go
View File

@ -96,9 +96,9 @@ func (a *azureServiceBus) Publish(ctx context.Context, req *pubsub.PublishReques
}
// Try sending the message
parentCtx, cancel := context.WithTimeout(ctx, time.Second*time.Duration(a.metadata.TimeoutInSec))
defer cancel()
err = sender.SendMessage(parentCtx, msg, nil)
publishCtx, publisCancel := context.WithTimeout(ctx, time.Second*time.Duration(a.metadata.TimeoutInSec))
err = sender.SendMessage(publishCtx, msg, nil)
publisCancel()
if err != nil {
if impl.IsNetworkError(err) {
// Retry after reconnecting

6
pubsub/azure/servicebus/topics/servicebus.go
View File

@ -95,9 +95,9 @@ func (a *azureServiceBus) Publish(ctx context.Context, req *pubsub.PublishReques
}
// Try sending the message
parentCtx, cancel := context.WithTimeout(ctx, time.Second*time.Duration(a.metadata.TimeoutInSec))
defer cancel()
err = sender.SendMessage(parentCtx, msg, nil)
publishCtx, publishCancel := context.WithTimeout(ctx, time.Second*time.Duration(a.metadata.TimeoutInSec))
err = sender.SendMessage(publishCtx, msg, nil)
publishCancel()
if err != nil {
if impl.IsNetworkError(err) {
// Retry after reconnecting