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

update comment 

Signed-off-by: Joni Collinge <jonathancollinge@live.com>
This commit is contained in:
Joni Collinge 2022-12-09 15:05:52 +00:00
parent df3afc64ce
commit f27ef6d46b
No known key found for this signature in database
GPG Key ID: BF9B59005264DD95
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -338,6 +338,7 @@ func (a *azureServiceBus) ConnectAndReceive(subscribeCtx context.Context,
closeReceiverCancel()
}()
// lock renewal loop
go func() {
a.logger.Debugf("Renewing locks for subscription %s for topic %s", a.metadata.ConsumerID, req.Topic)
lockErr := sub.RenewLocksBlocking(receiverCtx, receiver, impl.LockRenewalOptions{
@ -439,6 +440,7 @@ func (a *azureServiceBus) ConnectAndReceiveWithSessions(subscribeCtx context.Con
closeReceiverCancel()
}()
// lock renewal loop
go func() {
a.logger.Debugf("Renewing locks for session %s receiver for subscription %s to topic %s", sessionID, a.metadata.ConsumerID, req.Topic)
lockErr := sub.RenewLocksBlocking(receiverCtx, receiver, impl.LockRenewalOptions{