Skip to content

Commit f42fc03

Browse files
committed
fix: variable name error
1 parent c6b857e commit f42fc03

1 file changed

Lines changed: 8 additions & 12 deletions

File tree

src/modules/general/rmq/rmqPool.go

Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ type Service struct {
2424

2525
connections map[int]connection
2626
channels map[int]channel
27-
idelChannels []int
27+
idleChannels []int
2828
busyChannels map[int]int
2929
m *sync.Mutex
3030
wg *sync.WaitGroup
@@ -125,7 +125,7 @@ func (S *Service) channelPool() {
125125
for j := 0; j < S.ChannelNum; j++ {
126126
key := index*S.ChannelNum + j
127127
S.channels[key] = S.createChannel(index)
128-
S.idelChannels = append(S.idelChannels, key)
128+
S.idleChannels = append(S.idleChannels, key)
129129
}
130130
}
131131
}
@@ -298,19 +298,15 @@ func (S *Service) NotifyReturn(notifier func(message amqp.Return), ch *amqp.Chan
298298
func (S *Service) getChannel() (*amqp.Channel, int) {
299299
S.m.Lock()
300300
defer S.m.Unlock()
301-
idelLength := len(S.idelChannels)
302-
if idelLength > 0 {
301+
idleLength := len(S.idleChannels)
302+
if idleLength > 0 {
303303
rand.Seed(time.Now().Unix())
304-
index := rand.Intn(idelLength)
305-
channelId := S.idelChannels[index]
306-
S.idelChannels = append(S.idelChannels[:index], S.idelChannels[index+1:]...)
304+
index := rand.Intn(idleLength)
305+
channelId := S.idleChannels[index]
306+
S.idleChannels = append(S.idleChannels[:index], S.idleChannels[index+1:]...)
307307
S.busyChannels[channelId] = channelId
308308

309309
ch := S.channels[channelId].ch
310-
//log.Println("channels count: ",len(S.channels))
311-
//log.Println("idel channels count: ",len(S.idelChannels))
312-
//log.Println("busy channels count: ",len(S.busyChannels))
313-
//log.Println("channel id: ",channelId)
314310
return ch, channelId
315311
} else {
316312
//return S.createChannel(0,S.connections[0]),-1
@@ -450,7 +446,7 @@ func (S *Service) backChannelId(channelId int, ch *amqp.Channel) {
450446
}
451447
S.m.Lock()
452448
defer S.m.Unlock()
453-
S.idelChannels = append(S.idelChannels, channelId)
449+
S.idleChannels = append(S.idleChannels, channelId)
454450
delete(S.busyChannels, channelId)
455451
return
456452
}

0 commit comments

Comments
 (0)