diff --git a/channel.js b/channel.js index 6e20936b..7a2b0122 100644 --- a/channel.js +++ b/channel.js @@ -651,6 +651,11 @@ Channel.prototype.tryQueue = function(user, data) { !this.opts.qopen_allow_qnext) { return; } + + if(user.noflood("queue", 0.25)) { + return; + } + this.enqueue(data); }