removed excessive logging
This commit is contained in:
@@ -146,9 +146,6 @@ class ThrottlingHandler(
|
|||||||
if (head is LastHttpContent) break
|
if (head is LastHttpContent) break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
log.debug {
|
|
||||||
"Queue size: ${queuedContent.stream().filter { it !is RefusedRequest }.count()}"
|
|
||||||
}
|
|
||||||
if(queuedContent.isEmpty()) {
|
if(queuedContent.isEmpty()) {
|
||||||
valveClosed = false
|
valveClosed = false
|
||||||
} else {
|
} else {
|
||||||
@@ -180,9 +177,6 @@ class ThrottlingHandler(
|
|||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
super.channelRead(ctx, msg)
|
super.channelRead(ctx, msg)
|
||||||
log.debug {
|
|
||||||
"Queue size: ${queuedContent.stream().filter { it !is RefusedRequest }.count()}"
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user