Skip to content

Commit fbd29c9

Browse files
author
kuba--
committed
Remove commented leftovers
Signed-off-by: kuba-- <kuba@sourced.tech>
1 parent df1923f commit fbd29c9

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

amqp/amqp.go

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -115,21 +115,14 @@ func (b *Broker) manageConnection(url string) {
115115
if err == nil {
116116
break
117117
}
118-
119-
// b.mut.Lock()
120118
b.reconnect(url)
121-
// b.mut.Unlock()
122-
break
123119

124120
case err := <-b.chErrors:
125121
log.Errorf(err, "amqp channel error - reopening channel")
126122
if err == nil {
127123
break
128124
}
129-
130-
// b.mut.Lock()
131125
b.reopenChannel()
132-
// b.mut.Unlock()
133126

134127
case <-b.stop:
135128
return

0 commit comments

Comments
 (0)