Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Fixing a channel closing bug

  • Loading branch information...
commit 9baa2f7051cbeb7de14c6fd164a4cccc7f5f1453 1 parent 9e48060
@nate nate authored
Showing with 1 addition and 1 deletion.
  1. +1 −1  lib/agent/channel.rb
View
2  lib/agent/channel.rb
@@ -99,7 +99,7 @@ def pop?; queue.pop?; end
def close
return if @state == :closed
@state = :closed
- queue.close
+ @queue.close
Queues.remove(@name)
end
def closed?; @state == :closed; end
Please sign in to comment.
Something went wrong with that request. Please try again.