class Fluent::Plugin::ForwardOutput::Node::SocketCache

def revoke(key = Thread.current.object_id)
  @mutex.synchronize do
    if @active_socks[key]
      @inactive_socks[key] = @active_socks.delete(key)
      @inactive_socks[key].ref = 0
    end
  end
end