diff options
Diffstat (limited to 'lib/yahns/server.rb')
| -rw-r--r-- | lib/yahns/server.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/yahns/server.rb b/lib/yahns/server.rb index 462717b..4bd523f 100644 --- a/lib/yahns/server.rb +++ b/lib/yahns/server.rb @@ -344,10 +344,10 @@ class Yahns::Server # :nodoc: opts = sock_opts(l) ctx = opts[:yahns_app_ctx] qegg = ctx.qegg || @config.qeggs[:default] - q = queues[qegg] ||= qegg_vivify(qegg, fdmap) + ctx.queue = queues[qegg] ||= qegg_vivify(qegg, fdmap) # acceptors feed the the queues - l.spawn_acceptor(opts[:threads] || 1, @logger, ctx, q) + l.spawn_acceptor(opts[:threads] || 1, @logger, ctx) end fdmap end |