incubator-connectors-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r911029 [13/19] - in /incubator/lcf/trunk: modules/connectors/documentum/connector/org/apache/lcf/crawler/authorities/DCTM/ modules/connectors/documentum/connector/org/apache/lcf/crawler/connectors/DCTM/ modules/connectors/documentum/crawle...
Date Wed, 17 Feb 2010 15:57:35 GMT
Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connectors/BaseRepositoryConnector.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connectors/BaseRepositoryConnector.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connectors/BaseRepositoryConnector.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connectors/BaseRepositoryConnector.java Wed Feb 17 15:57:27 2010
@@ -25,7 +25,7 @@
 import java.io.*;
 import java.util.*;
 
-/** This base class describes an instance of a connection between a repository and Metacarta's
+/** This base class describes an instance of a connection between a repository and LCF's
 * standard "pull" ingestion agent.
 *
 * Each instance of this interface is used in only one thread at a time.  Connection Pooling
@@ -82,7 +82,7 @@
 	*@param threadContext is the current thread context.
 	*/
 	public void install(IThreadContext threadContext)
-		throws MetacartaException
+		throws LCFException
 	{
 		// Base install does nothing
 	}
@@ -93,7 +93,7 @@
 	*@param threadContext is the current thread context.
 	*/
 	public void deinstall(IThreadContext threadContext)
-		throws MetacartaException
+		throws LCFException
 	{
 		// Base uninstall does nothing
 	}
@@ -130,7 +130,7 @@
 	*@return the connection's status as a displayable string.
 	*/
 	public String check()
-		throws MetacartaException
+		throws LCFException
 	{
 		// Base version returns "OK" status.
 		return "Connection working";
@@ -140,7 +140,7 @@
 	* in active use.
 	*/
 	public void poll()
-		throws MetacartaException
+		throws LCFException
 	{
 		// Base version does nothing
 	}
@@ -148,7 +148,7 @@
 	/** Close the connection.  Call this before discarding the repository connector.
 	*/
 	public void disconnect()
-		throws MetacartaException
+		throws LCFException
 	{
 		params = null;
 	}
@@ -223,7 +223,7 @@
 	*/
 	public void addSeedDocuments(ISeedingActivity activities, DocumentSpecification spec,
 		long startTime, long endTime, int jobMode)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		addSeedDocuments(activities,spec,startTime,endTime);
 	}
@@ -255,7 +255,7 @@
 	*/
 	public void addSeedDocuments(ISeedingActivity activities, DocumentSpecification spec,
 		long startTime, long endTime)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		// Call the old-style methods that get document identifiers, and then queue
 		// them using the new activities-based methods
@@ -304,7 +304,7 @@
 	*/
 	public IDocumentIdentifierStream getDocumentIdentifiers(ISeedingActivity activities, DocumentSpecification spec,
 		long startTime, long endTime)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		return getDocumentIdentifiers(spec,startTime,endTime);
 	}
@@ -317,7 +317,7 @@
 	*/
 	public IDocumentIdentifierStream getDocumentIdentifiers(DocumentSpecification spec,
 		long startTime, long endTime)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		// Something provided here so we can override either one.
 		return null;
@@ -340,7 +340,7 @@
 	*/
 	public IDocumentIdentifierStream getRemainingDocumentIdentifiers(ISeedingActivity activities, DocumentSpecification spec,
 		long startTime, long endTime)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		// Usually we don't need to worry about this.
 		return null;
@@ -365,7 +365,7 @@
 	*/
 	public String[] getDocumentVersions(String[] documentIdentifiers, String[] oldVersions, IVersionActivity activities,
 		DocumentSpecification spec, int jobMode, boolean usesDefaultAuthority)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		return getDocumentVersions(documentIdentifiers,oldVersions,activities,spec,jobMode);
 	}
@@ -388,7 +388,7 @@
 	*/
 	public String[] getDocumentVersions(String[] documentIdentifiers, String[] oldVersions, IVersionActivity activities,
 		DocumentSpecification spec, int jobMode)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		return getDocumentVersions(documentIdentifiers,oldVersions,activities,spec);
 	}
@@ -409,7 +409,7 @@
 	* will always be processed.
 	*/
 	public String[] getDocumentVersions(String[] documentIdentifiers, String[] oldVersions, IVersionActivity activities, DocumentSpecification spec)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		return getDocumentVersions(documentIdentifiers,activities,spec);
 	}
@@ -428,7 +428,7 @@
 	* will always be processed.
 	*/
 	public String[] getDocumentVersions(String[] documentIdentifiers, IVersionActivity activities, DocumentSpecification spec)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		return getDocumentVersions(documentIdentifiers,spec);
 	}
@@ -446,7 +446,7 @@
 	* will always be processed.
 	*/
 	public String[] getDocumentVersions(String[] documentIdentifiers, DocumentSpecification spec)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		// Return unknown versions
 		String[] rval = new String[documentIdentifiers.length];
@@ -466,7 +466,7 @@
 	*@param versions is the corresponding set of version identifiers (individual identifiers may be null).
 	*/
 	public void releaseDocumentVersions(String[] documentIdentifiers, String[] versions)
-		throws MetacartaException
+		throws LCFException
 	{
 		// Base implementation does nothing
 	}
@@ -496,7 +496,7 @@
 	*/
 	public void processDocuments(String[] documentIdentifiers, String[] versions, IProcessActivity activities,
 		DocumentSpecification spec, boolean[] scanOnly, int jobMode)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		processDocuments(documentIdentifiers,versions,activities,spec,scanOnly);
 	}
@@ -516,7 +516,7 @@
 	*/
 	public void processDocuments(String[] documentIdentifiers, String[] versions, IProcessActivity activities,
 		DocumentSpecification spec, boolean[] scanOnly)
-		throws MetacartaException, ServiceInterruption
+		throws LCFException, ServiceInterruption
 	{
 		// Does nothing; override to make something happen
 	}

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connmgr/ConnectorManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connmgr/ConnectorManager.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connmgr/ConnectorManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/connmgr/ConnectorManager.java Wed Feb 17 15:57:27 2010
@@ -41,7 +41,7 @@
 	*@param database is the database handle.
 	*/
 	public ConnectorManager(IThreadContext threadContext, IDBInterface database)
-		throws MetacartaException
+		throws LCFException
 	{
 		super(database,"connectors");
 		this.threadContext = threadContext;
@@ -51,7 +51,7 @@
 	/** Install or upgrade.
 	*/
 	public void install()
-		throws MetacartaException
+		throws LCFException
 	{
 		beginTransaction();
 		try
@@ -71,7 +71,7 @@
 				addTableIndex(true,list);
 			}
 		}
-		catch (MetacartaException e)
+		catch (LCFException e)
 		{
 			signalRollback();
 			throw e;
@@ -91,7 +91,7 @@
 	/** Uninstall.  This also unregisters all connectors.
 	*/
 	public void deinstall()
-		throws MetacartaException
+		throws LCFException
 	{
 		StringSet invKeys = new StringSet(getCacheKey());
 
@@ -110,7 +110,7 @@
 			}
 			performDrop(invKeys);
 		}
-		catch (MetacartaException e)
+		catch (LCFException e)
 		{
 			signalRollback();
 			throw e;
@@ -132,7 +132,7 @@
 	*@param className is the class name.
 	*/
 	public void registerConnector(String description, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		StringSet invKeys = new StringSet(getCacheKey());
 		beginTransaction();
@@ -159,7 +159,7 @@
 			// Either way, we must do the install/upgrade itself.
 			RepositoryConnectorFactory.install(threadContext,className);
 		}
-		catch (MetacartaException e)
+		catch (LCFException e)
 		{
 			signalRollback();
 			throw e;
@@ -180,7 +180,7 @@
 	*@param description is the description to unregister.
 	*/
 	public void unregisterConnector(String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		StringSet invKeys = new StringSet(getCacheKey());
 		beginTransaction();
@@ -191,7 +191,7 @@
 
 			removeConnector(className);
 		}
-		catch (MetacartaException e)
+		catch (LCFException e)
 		{
 			signalRollback();
 			throw e;
@@ -213,7 +213,7 @@
 	*@param className is the connector class to remove.
 	*/
 	public void removeConnector(String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		StringSet invKeys = new StringSet(getCacheKey());
 		ArrayList list = new ArrayList();
@@ -226,7 +226,7 @@
 	* These will be ordered by description.
 	*/
 	public IResultSet getConnectors()
-		throws MetacartaException
+		throws LCFException
 	{
 		StringSet invKeys = new StringSet(getCacheKey());
 
@@ -239,7 +239,7 @@
 	*@return the description, or null if the class is not registered.
 	*/
 	public String getDescription(String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		StringSet invKeys = new StringSet(getCacheKey());
 
@@ -258,7 +258,7 @@
 	*@return true if installed, false otherwise.
 	*/
 	public boolean isInstalled(String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		// Use the global table key; that's good enough because we don't expect stuff to change out from under very often.
 		StringSet invKeys = new StringSet(getCacheKey());

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ConnectorManagerFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ConnectorManagerFactory.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ConnectorManagerFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ConnectorManagerFactory.java Wed Feb 17 15:57:27 2010
@@ -38,16 +38,16 @@
 	*@return the connector manager handle.
 	*/
 	public static IConnectorManager make(IThreadContext tc)
-		throws MetacartaException
+		throws LCFException
 	{
 		Object o = tc.get(connMgr);
 		if (o == null || !(o instanceof IConnectorManager))
 		{
 
 			IDBInterface database = DBInterfaceFactory.make(tc,
-				Metacarta.getMasterDatabaseName(),
-				Metacarta.getMasterDatabaseUsername(),
-				Metacarta.getMasterDatabasePassword());
+				LCF.getMasterDatabaseName(),
+				LCF.getMasterDatabaseUsername(),
+				LCF.getMasterDatabasePassword());
 
 			o = new org.apache.lcf.crawler.connmgr.ConnectorManager(tc,database);
 			tc.save(connMgr,o);

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/DocumentSpecification.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/DocumentSpecification.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/DocumentSpecification.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/DocumentSpecification.java Wed Feb 17 15:57:27 2010
@@ -38,7 +38,7 @@
 	*@param xml is the input XML.
 	*/
 	public DocumentSpecification(String xml)
-		throws MetacartaException
+		throws LCFException
 	{
 		super(xml);
 	}

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IAbortActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IAbortActivity.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IAbortActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IAbortActivity.java Wed Feb 17 15:57:27 2010
@@ -34,6 +34,6 @@
         * caller, will signal that the current seeding activity remains incomplete and must be retried when the job is resumed.
         */
         public void checkJobStillActive()
-                throws MetacartaException, ServiceInterruption;
+                throws LCFException, ServiceInterruption;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IConnectorManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IConnectorManager.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IConnectorManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IConnectorManager.java Wed Feb 17 15:57:27 2010
@@ -30,12 +30,12 @@
 	/** Install.
 	*/
 	public void install()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Uninstall.  This also unregisters all connectors.
 	*/
 	public void deinstall()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Register a new connector.
 	* The connector's install method will also be called.
@@ -43,14 +43,14 @@
 	*@param className is the class name.
 	*/
 	public void registerConnector(String description, String className)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Unregister a connector.
 	* The connector's deinstall method will also be called.
 	*@param className is the connector class to unregister.
 	*/
 	public void unregisterConnector(String className)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Remove a connector.
 	* Use this method when the connector doesn't seem to be in the
@@ -58,27 +58,27 @@
 	*@param className is the connector class to remove.
 	*/
 	public void removeConnector(String className)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Get ordered list of connectors.
 	*@return a resultset with the columns "description" and "classname".
 	* These will be ordered by description.
 	*/
 	public IResultSet getConnectors()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Get a description given a class name.
 	*@param className is the class name.
 	*@return the description, or null if the class is not registered.
 	*/
 	public String getDescription(String className)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Check if a particular connector is installed or not.
 	*@param className is the class name of the connector.
 	*@return true if installed, false otherwise.
 	*/
 	public boolean isInstalled(String className)
-		throws MetacartaException;
+		throws LCFException;
 		
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IDocumentIdentifierStream.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IDocumentIdentifierStream.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IDocumentIdentifierStream.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IDocumentIdentifierStream.java Wed Feb 17 15:57:27 2010
@@ -37,11 +37,11 @@
 	*@return the next document identifier, or null if there are no more.
 	*/
 	public String getNextIdentifier()
-		throws MetacartaException, ServiceInterruption;
+		throws LCFException, ServiceInterruption;
 
 	/** Close the stream.
 	*/
 	public void close()
-		throws MetacartaException;
+		throws LCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IEventActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IEventActivity.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IEventActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IEventActivity.java Wed Feb 17 15:57:27 2010
@@ -74,7 +74,7 @@
         *@return false if the event is already in the "pending" state.
         */
         public boolean beginEventSequence(String eventName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Complete an event sequence.
         * This method should be called to signal that an event is no longer in the "pending" state.  This can mean that the prerequisite processing is
@@ -84,7 +84,7 @@
         *@param eventName is the event name.
         */
         public void completeEventSequence(String eventName)
-                throws MetacartaException;
+                throws LCFException;
                 
         /** Abort processing a document (for sequencing reasons).
         * This method should be called in order to cause the specified document to be requeued for later processing.  While this is similar in some respects
@@ -93,7 +93,7 @@
         *@param localIdentifier is the document identifier to requeue
         */
         public void retryDocumentProcessing(String localIdentifier)
-                throws MetacartaException;
+                throws LCFException;
 
    
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IHistoryActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IHistoryActivity.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IHistoryActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IHistoryActivity.java Wed Feb 17 15:57:27 2010
@@ -46,6 +46,6 @@
         */
         public void recordActivity(Long startTime, String activityType, Long dataSize,
                 String entityIdentifier, String resultCode, String resultDescription, String[] childIdentifiers)
-                throws MetacartaException;
+                throws LCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IJobManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IJobManager.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IJobManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IJobManager.java Wed Feb 17 15:57:27 2010
@@ -54,46 +54,46 @@
         /** Install the job manager's tables.
         */
         public void install()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Uninstall the job manager's tables.
         */
         public void deinstall()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Export configuration */
         public void exportConfiguration(java.io.OutputStream os)
-                throws java.io.IOException, MetacartaException;
+                throws java.io.IOException, LCFException;
         
         /** Import configuration */
         public void importConfiguration(java.io.InputStream is)
-                throws java.io.IOException, MetacartaException;
+                throws java.io.IOException, LCFException;
 
         /** Load a sorted list of job descriptions.
         *@return the list, sorted by description.
         */
         public IJobDescription[] getAllJobs()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Create a new job.
         *@return the new job.
         */
         public IJobDescription createJob()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Delete a job.
         *@param id is the job's identifier.  This method will purge all the records belonging to the job from the database, as
         * well as remove all documents indexed by the job from the index.
         */
         public void deleteJob(Long id)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Load a job for editing.
         *@param id is the job's identifier.
         *@return null if the job doesn't exist.
         */
         public IJobDescription load(Long id)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Load a job.
         *@param id is the job's identifier.
@@ -101,34 +101,34 @@
         *@return null if the job doesn't exist.
         */
         public IJobDescription load(Long id, boolean readOnly)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Save a job.
         *@param jobDescription is the job description.
         */
         public void save(IJobDescription jobDescription)
-                throws MetacartaException;
+                throws LCFException;
 
         /** See if there's a reference to a connection name.
         *@param connectionName is the name of the connection.
         *@return true if there is a reference, false otherwise.
         */
         public boolean checkIfReference(String connectionName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** See if there's a reference to an output connection name.
         *@param connectionName is the name of the connection.
         *@return true if there is a reference, false otherwise.
         */
         public boolean checkIfOutputReference(String connectionName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get the job IDs associated with a given connection name.
         *@param connectionName is the name of the connection.
         *@return the set of job id's associated with that connection.
         */
         public IJobDescription[] findJobsForConnection(String connectionName)
-                throws MetacartaException;
+                throws LCFException;
                 
         // These methods cover activities that require interaction with the job queue.
         // The job queue is maintained underneath this interface, and all threads that perform
@@ -141,27 +141,27 @@
         * state.
         */
         public void prepareForStart()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset as part of restoring document worker threads.
         */
         public void resetDocumentWorkerStatus()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset as part of restoring seeding threads.
         */
         public void resetSeedingWorkerStatus()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset as part of restoring doc delete threads.
         */
         public void resetDocDeleteWorkerStatus()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset as part of restoring startup threads.
         */
         public void resetStartupWorkerStatus()
-                throws MetacartaException;
+                throws LCFException;
 
         // These methods support the "set doc priority" thread
 
@@ -173,7 +173,7 @@
         *@return the document descriptions.
         */
         public DocumentDescription[] getNextAlreadyProcessedReprioritizationDocuments(long currentTime, int n)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get a list of not-yet-processed documents to reprioritize.  Documents in all jobs will be
         * returned by this method.  Up to n document descriptions will be returned.
@@ -183,7 +183,7 @@
         *@return the document descriptions.
         */
         public DocumentDescription[] getNextNotYetProcessedReprioritizationDocuments(long currentTime, int n)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Save a set of document priorities.  In the case where a document was eligible to have its
         * priority set, but it no longer is eligible, then the provided priority will not be written.
@@ -192,7 +192,7 @@
         *@param priorities are the desired priorities.
         */
         public void writeDocumentPriorities(long currentTime, DocumentDescription[] descriptions, double[] priorities)
-                throws MetacartaException;
+                throws LCFException;
 
         // This method supports the "expiration" thread
         
@@ -206,7 +206,7 @@
         *@return the array of document descriptions to expire.
         */
         public DocumentDescription[] getExpiredDocuments(int n, long currentTime)
-                throws MetacartaException;
+                throws LCFException;
                 
         // This method supports the "queue stuffer" thread
 
@@ -229,7 +229,7 @@
         public DocumentDescription[] getNextDocuments(int n, long currentTime, long interval,
                 BlockingDocuments blockingDocuments, PerformanceStatistics statistics,
                 DepthStatistics scanRecord)
-                throws MetacartaException;
+                throws LCFException;
 
         // These methods support the individual fetch/process threads.
 
@@ -239,25 +239,25 @@
         *@return true if the job is in one of the "active" states.
         */
         public boolean checkJobActive(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Verify if a job is still processing documents, or no longer has any outstanding active documents */
         public boolean checkJobBusy(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
                 
         /** Note completion of document processing by a job thread of a document.
         * This method causes the state of the document to be marked as "completed".
         *@param documentDescriptions are the description objects for the documents that were processed.
         */
         public void markDocumentCompletedMultiple(DocumentDescription[] documentDescriptions)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Note completion of document processing by a job thread of a document.
         * This method causes the state of the document to be marked as "completed".
         *@param documentDescription is the description object for the document that was processed.
         */
         public void markDocumentCompleted(DocumentDescription documentDescription)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Note deletion as result of document processing by a job thread of a document.
         *@param documentDescriptions are the set of description objects for the documents that were processed.
@@ -267,7 +267,7 @@
         */
         public DocumentDescription[] markDocumentDeletedMultiple(Long jobID, String[] legalLinkTypes, DocumentDescription[] documentDescriptions,
                 int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Note deletion as result of document processing by a job thread of a document.
         *@param documentDescription is the description object for the document that was processed.
@@ -277,7 +277,7 @@
         */
         public DocumentDescription[] markDocumentDeleted(Long jobID, String[] legalLinkTypes, DocumentDescription documentDescription,
                 int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Requeue a document set because of carrydown changes.
         * This method is called when carrydown data is modified for a set of documents.  The documents must be requeued for immediate reprocessing, even to the
@@ -287,7 +287,7 @@
         *@return a flag for each document priority, true if it was used, false otherwise.
         */
         public boolean[] carrydownChangeDocumentMultiple(DocumentDescription[] documentDescriptions, long currentTime, double[] docPriorities)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Requeue a document because of carrydown changes.
         * This method is called when carrydown data is modified for a document.  The document must be requeued for immediate reprocessing, even to the
@@ -297,7 +297,7 @@
         *@return a flag for the document priority, true if it was used, false otherwise.
         */
         public boolean carrydownChangeDocument(DocumentDescription documentDescription, long currentTime, double docPriority)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Requeue a document for further processing in the future.
         * This method is called after a document is processed, when the job is a "continuous" one.
@@ -309,7 +309,7 @@
         */
         public void requeueDocumentMultiple(DocumentDescription[] documentDescriptions, Long[] executeTimes,
                 int[] actions)
-                throws MetacartaException;
+                throws LCFException;
 
 
         /** Requeue a document for further processing in the future.
@@ -322,7 +322,7 @@
         */
         public void requeueDocument(DocumentDescription documentDescription, Long executeTime,
                 int action)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset documents for further processing in the future.
         * This method is called after a service interruption is thrown.
@@ -334,7 +334,7 @@
         */
         public void resetDocumentMultiple(DocumentDescription[] documentDescriptions, long executeTime,
                 int action, long failTime, int failCount)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset an active document back to its former state.
         * This gets done when there's a service interruption and the document cannot be processed yet.
@@ -346,7 +346,7 @@
         */
         public void resetDocument(DocumentDescription documentDescription, long executeTime, int action, long failTime,
                 int failCount)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset a set of deleting documents for further processing in the future.
         * This method is called after some unknown number of the documents were deleted, but then an ingestion service interruption occurred.
@@ -357,13 +357,13 @@
         *@param documentDescriptions is the set of description objects for the document that was processed.
         */
         public void resetDeletingDocumentMultiple(DocumentDescription[] documentDescriptions)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset a deleting document back to its former state.
         * This gets done when a deleting thread sees a service interruption, etc., from the ingestion system.
         */
         public void resetDeletingDocument(DocumentDescription documentDescription)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add an initial set of documents to the queue.
         * This method is called during job startup, when the queue is being loaded.
@@ -384,7 +384,7 @@
                 String[] docIDHashes, String[] docIDs, boolean overrideSchedule,
                 int hopcountMethod, long currentTime, double[] documentPriorities,
                 String[][] prereqEventNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add an initial set of remaining documents to the queue.
         * This method is called during job startup, when the queue is being loaded, to list documents that
@@ -398,7 +398,7 @@
         public void addRemainingDocumentsInitial(Long jobID, String[] legalLinkTypes,
                 String[] docIDHashes,
                 int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Signal that a seeding pass has been done.
         * Call this method at the end of a seeding pass.  It is used to perform the bookkeeping necessary to
@@ -411,20 +411,20 @@
         */
         public void doneDocumentsInitial(Long jobID, String[] legalLinkTypes, boolean isPartial,
                 int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Begin an event sequence.
         *@param eventName is the name of the event.
         *@return true if the event could be created, or false if it's already there.
         */
         public boolean beginEventSequence(String eventName)
-                throws MetacartaException;
+                throws LCFException;
                 
         /** Complete an event sequence.
         *@param eventName is the name of the event.
         */
         public void completeEventSequence(String eventName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get the specified hop counts, with the limit as described.
         *@param jobID is the job identifier.
@@ -438,7 +438,7 @@
         */
         public boolean[] findHopCounts(Long jobID, String[] legalLinkTypes, String[] docIDHashes, String linkType, int limit,
                 int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get all the current seeds.
         * Returns the seed document identifiers for a job.
@@ -446,7 +446,7 @@
         *@return the document identifier hashes that are currently considered to be seeds.
         */
         public String[] getAllSeeds(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add a document to the queue.
         * This method is called during document processing, when a document reference is discovered.
@@ -475,7 +475,7 @@
                 String relationshipType,
                 int hopcountMethod, String[] dataNames, Object[][] dataValues,
                 long currentTime, double priority, String[] prereqEventNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add documents to the queue in bulk.
         * This method is called during document processing, when a set of document references are discovered.
@@ -504,7 +504,7 @@
                 int hopcountMethod, String[][] dataNames, Object[][][] dataValues,
                 long currentTime, double[] priorities,
                 String[][] prereqEventNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Complete adding child documents to the queue, for a set of documents.
         * This method is called at the end of document processing, to help the hopcount tracking engine do its bookkeeping.
@@ -517,7 +517,7 @@
         */
         public DocumentDescription[] finishDocuments(Long jobID, String[] legalLinkTypes,
                 String[] parentIdentifierHashes, int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Retrieve specific parent data for a given document.
         *@param jobID is the job identifier.
@@ -526,7 +526,7 @@
         *@return the unique data values.
         */
         public String[] retrieveParentData(Long jobID, String docIDHash, String dataName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Retrieve specific parent data for a given document.
         *@param jobID is the job identifier.
@@ -535,7 +535,7 @@
         *@return the unique data values.
         */
         public CharacterInput[] retrieveParentDataAsFiles(Long jobID, String docIDHash, String dataName)
-                throws MetacartaException;
+                throws LCFException;
 
         // These methods support the job threads (which start jobs and end jobs)
         // There is one thread that starts jobs.  It simply looks for jobs which are ready to
@@ -549,40 +549,40 @@
         *@param jobID is the ID of the job to start.
         */
         public void manualStart(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Manually abort a running job.  The job will be permanently stopped, and will not run again until
         * automatically started based on schedule, or manually started.
         *@param jobID is the job to abort.
         */
         public void manualAbort(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Manually restart a running job.  The job will be stopped and restarted.  Any schedule affinity will be lost,
         * until the job finishes on its own.
         *@param jobID is the job to abort.
         */
         public void manualAbortRestart(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Pause a job.
         *@param jobID is the job identifier to pause.
         */
         public void pauseJob(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Restart a paused job.
         *@param jobID is the job identifier to restart.
         */
         public void restartJob(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset job schedule.  This re-evaluates whether the job should be started now.  This method would typically
         * be called after a job's scheduling window has been changed.
         *@param jobID is the job identifier.
         */
         public void resetJobSchedule(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         // These methods are called by automatic processes
 
@@ -593,7 +593,7 @@
         *@param unwaitList is filled in with the set of job id's that were resumed (Long's).
         */
         public void startJobs(long currentTime, ArrayList unwaitList)
-                throws MetacartaException;
+                throws LCFException;
 
 
         /** Put active or paused jobs in wait state, if they've exceeded their window.
@@ -601,7 +601,7 @@
         *@param waitList is filled in with the set of job id's that were put into a wait state (Long's).
         */
         public void waitJobs(long currentTime, ArrayList waitList)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get the list of jobs that are ready for seeding.
         *@param currentTime is the current time in milliseconds since epoch.
@@ -609,54 +609,54 @@
         * based on what the connector says should be added to the queue.
         */
         public JobStartRecord[] getJobsReadyForSeeding(long currentTime)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset a seeding job back to "active" state.
         *@param jobID is the job id.
         */
         public void resetSeedJob(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get the list of jobs that are ready for startup.
         *@return jobs that were in the "readyforstartup" state.  These will be marked as being in the "starting up" state.
         */
         public JobStartRecord[] getJobsReadyForStartup()
-                throws MetacartaException;
+                throws LCFException;
 
 
         /** Reset a starting job back to "ready for startup" state.
         *@param jobID is the job id.
         */
         public void resetStartupJob(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Prepare for a full scan.
         *@param jobID is the job id.
         *@param hopcountMethod describes how to handle deletions for hopcount purposes.
         */
         public void prepareFullScan(Long jobID, String[] legalLinkTypes, int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Prepare for an incremental scan.
         *@param jobID is the job id.
         *@param hopcountMethod describes how to handle deletions for hopcount purposes.
         */
         public void prepareIncrementalScan(Long jobID, String[] legalLinkTypes, int hopcountMethod)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Note job started.
         *@param jobID is the job id.
         *@param startTime is the job start time.
         */
         public void noteJobStarted(Long jobID, long startTime)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Note job seeded.
         *@param jobID is the job id.
         *@param startTime is the job seed time.
         */
         public void noteJobSeeded(Long jobID, long startTime)
-                throws MetacartaException;
+                throws LCFException;
 
         /**  Note the deregistration of a connector used by the specified connections.
         * This method will be called when the connector is deregistered.  Jobs that use these connections
@@ -664,7 +664,7 @@
         *@param connectionNames is the set of connection names.
         */
         public void noteConnectorDeregistration(String[] connectionNames)
-                throws MetacartaException;
+                throws LCFException;
                 
         /** Note the registration of a connector used by the specified connections.
         * This method will be called when a connector is registered, on which the specified
@@ -672,7 +672,7 @@
         *@param connectionNames is the set of connection names.
         */
         public void noteConnectorRegistration(String[] connectionNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /**  Note the deregistration of an output connector used by the specified connections.
         * This method will be called when the connector is deregistered.  Jobs that use these connections
@@ -680,7 +680,7 @@
         *@param connectionNames is the set of connection names.
         */
         public void noteOutputConnectorDeregistration(String[] connectionNames)
-                throws MetacartaException;
+                throws LCFException;
                 
         /** Note the registration of an output connector used by the specified connections.
         * This method will be called when a connector is registered, on which the specified
@@ -688,13 +688,13 @@
         *@param connectionNames is the set of connection names.
         */
         public void noteOutputConnectorRegistration(String[] connectionNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Delete jobs in need of being deleted (which are marked "ready for delete").
         * This method is meant to be called periodically to perform delete processing on jobs.
         */
         public void deleteJobsReadyForDelete()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get list of deletable document descriptions.  This list will take into account
         * multiple jobs that may own the same document.
@@ -702,7 +702,7 @@
         *@return the document descriptions for these documents.
         */
         public DocumentDescription[] getNextDeletableDocuments(int n)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Delete ingested document identifiers (as part of deleting the owning job).
         * The number of identifiers specified is guaranteed to be less than the maxInClauseCount
@@ -710,7 +710,7 @@
         *@param identifiers is the set of document identifiers.
         */
         public void deleteIngestedDocumentIdentifiers(DocumentDescription[] identifiers)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Abort a running job due to a fatal error condition.
         *@param jobID is the job to abort.
@@ -718,27 +718,27 @@
         *@return true if this is the first abort for the job.
         */
         public boolean errorAbort(Long jobID, String errorText)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Complete the sequence that aborts jobs and makes them runnable again.
         *@param currentTime is the current time in milliseconds since epoch.
         *@param abortJobs is filled in with the set of IJobDescription objects that were aborted.
         */
         public void finishJobAborts(long timestamp, ArrayList abortJobs)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Put all eligible jobs in the "shutting down" state.
         *@param finishList is filled in with the set of IJobDescription objects that were completed.
         */
         public void finishJobs(ArrayList finishList)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Reset eligible jobs back to "inactive" state.  This method is used to pick up all jobs in the shutting down state
         * whose purgatory records have been all cleaned up.
         *@param currentTime is the current time in milliseconds since epoch.
         */
         public void resetJobs(long currentTime)
-                throws MetacartaException;
+                throws LCFException;
 
 
         // Status reports
@@ -747,25 +747,25 @@
         *@return the status object for the specified job.
         */
         public JobStatus getStatus(Long jobID)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get a list of all jobs, and their status information.
         *@return an ordered array of job status objects.
         */
         public JobStatus[] getAllStatus()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get a list of running jobs.  This is for status reporting.
         *@return an array of the job status objects.
         */
         public JobStatus[] getRunningJobs()
-                throws MetacartaException;
+                throws LCFException;
 
         /** Get a list of completed jobs, and their statistics.
         *@return an array of the job status objects.
         */
         public JobStatus[] getFinishedJobs()
-                throws MetacartaException;
+                throws LCFException;
 
         // The following commands generate reports based on the queue.
         
@@ -780,7 +780,7 @@
         */
         public IResultSet genDocumentStatus(String connectionName, StatusFilterCriteria filterCriteria, SortOrder sortOrder,
                 int startRow, int rowCount)
-                throws MetacartaException;
+                throws LCFException;
                 
         /** Run a 'queue status' report.
         *@param connectionName is the name of the connection.
@@ -794,5 +794,5 @@
         */
         public IResultSet genQueueStatus(String connectionName, StatusFilterCriteria filterCriteria, SortOrder sortOrder,
                 BucketDescription idBucketDescription, int startRow, int rowCount)
-                throws MetacartaException;
+                throws LCFException;
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IProcessActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IProcessActivity.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IProcessActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IProcessActivity.java Wed Feb 17 15:57:27 2010
@@ -44,7 +44,7 @@
         */
         public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType,
                 String[] dataNames, Object[][] dataValues, Long originationTime, String[] prereqEventNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add a document description to the current job's queue.
         *@param localIdentifier is the local document identifier to add (for the connector that
@@ -61,7 +61,7 @@
         */
         public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType,
                 String[] dataNames, Object[][] dataValues, Long originationTime)
-                throws MetacartaException;
+                throws LCFException;
 
 
         /** Add a document description to the current job's queue.
@@ -78,7 +78,7 @@
         */
         public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType,
                 String[] dataNames, Object[][] dataValues)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add a document description to the current job's queue.
         *@param localIdentifier is the local document identifier to add (for the connector that
@@ -90,7 +90,7 @@
         * "getRelationshipTypes()".  May be null.
         */
         public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Add a document description to the current job's queue.  This method is equivalent to
         * addDocumentReference(localIdentifier,null,null).
@@ -98,7 +98,7 @@
         * fetched the document).
         */
         public void addDocumentReference(String localIdentifier)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Retrieve data passed from parents to a specified child document.
         *@param localIdentifier is the document identifier of the document we want the recorded data for.
@@ -106,7 +106,7 @@
         *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
         */
         public String[] retrieveParentData(String localIdentifier, String dataName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Retrieve data passed from parents to a specified child document.
         *@param localIdentifier is the document identifier of the document we want the recorded data for.
@@ -114,14 +114,14 @@
         *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
         */
         public CharacterInput[] retrieveParentDataAsFiles(String localIdentifier, String dataName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Record a document version, but don't ingest it.
         *@param localIdentifier is the document identifier.
         *@param version is the document version.
         */
         public void recordDocument(String localIdentifier, String version)
-                throws MetacartaException, ServiceInterruption;
+                throws LCFException, ServiceInterruption;
 
         /** Ingest the current document.
         *@param localIdentifier is the document's local identifier.
@@ -132,13 +132,13 @@
         *@param data is the document data.  The data is closed after ingestion is complete.
         */
         public void ingestDocument(String localIdentifier, String version, String documentURI, RepositoryDocument data)
-                throws MetacartaException, ServiceInterruption;
+                throws LCFException, ServiceInterruption;
 
         /** Delete the current document from the search engine index.
         *@param localIdentifier is the document's local identifier.
         */
         public void deleteDocument(String localIdentifier)
-                throws MetacartaException, ServiceInterruption;
+                throws LCFException, ServiceInterruption;
 
         /** Override the schedule for the next time a document is crawled.
         * Calling this method allows you to set an upper recrawl bound, lower recrawl bound, upper expire bound, lower expire bound,
@@ -153,7 +153,7 @@
         public void setDocumentScheduleBounds(String localIdentifier,
                 Long lowerRecrawlBoundTime, Long upperRecrawlBoundTime,
                 Long lowerExpireBoundTime, Long upperExpireBoundTime)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Override a document's origination time.
         * Use this method to signal the framework that a document's origination time is something other than the first time it was crawled.
@@ -162,6 +162,6 @@
         */
         public void setDocumentOriginationTime(String localIdentifier,
                 Long originationTime)
-                throws MetacartaException;
+                throws LCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnectionManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnectionManager.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnectionManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnectionManager.java Wed Feb 17 15:57:27 2010
@@ -29,33 +29,33 @@
 	/** Install the manager.
 	*/
 	public void install()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Uninstall the manager.
 	*/
 	public void deinstall()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Export configuration */
 	public void exportConfiguration(java.io.OutputStream os)
-		throws java.io.IOException, MetacartaException;
+		throws java.io.IOException, LCFException;
 	
 	/** Import configuration */
 	public void importConfiguration(java.io.InputStream is)
-		throws java.io.IOException, MetacartaException;
+		throws java.io.IOException, LCFException;
 	
 	/** Obtain a list of the repository connections, ordered by name.
 	*@return an array of connection objects.
 	*/
 	public IRepositoryConnection[] getAllConnections()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Load a repository connection by name.
 	*@param name is the name of the repository connection.
 	*@return the loaded connection object, or null if not found.
 	*/
 	public IRepositoryConnection load(String name)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Load a set of repository connections.
 	*@param names are the names of the repository connections.
@@ -63,47 +63,47 @@
 	* values for those not found.
 	*/
 	public IRepositoryConnection[] loadMultiple(String[] names)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Create a new repository connection object.
 	*@return the new object.
 	*/
 	public IRepositoryConnection create()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Save a repository connection object.
 	*@param object is the object to save.
 	*/
 	public void save(IRepositoryConnection object)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Delete a repository connection.
 	*@param name is the name of the connection to delete.  If the
 	* name does not exist, no error is returned.
 	*/
 	public void delete(String name)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Return true if the specified authority name is referenced.
 	*@param authorityName is the authority name.
 	*@return true if referenced, false otherwise.
 	*/
 	public boolean isReferenced(String authorityName)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Get a list of repository connections that share the same connector.
 	*@param className is the class name of the connector.
 	*@return the repository connections that use that connector.
 	*/
 	public String[] findConnectionsForConnector(String className)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Check if underlying connector exists.
 	*@param name is the name of the connection to check.
 	*@return true if the underlying connector is registered.
 	*/
 	public boolean checkConnectorExists(String name)
-		throws MetacartaException;
+		throws LCFException;
 
 	// Schema related
 
@@ -160,7 +160,7 @@
 	*/
 	public void recordHistory(String connectionName, Long startTime, String activityType, Long dataSize,
 		String entityIdentifier, String resultCode, String resultDescription, String[] childIdentifiers)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Generate a report, listing the start time, elapsed time, result code and description, number of bytes, and entity identifier.
 	* The records selected for this report are based on the filtering criteria object passed into this method.
@@ -173,7 +173,7 @@
 	*@param is the maximum number of rows to include.
 	*/
 	public IResultSet genHistorySimple(String connectionName, FilterCriteria criteria, SortOrder sort, int startRow, int maxRowCount)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Count the number of rows specified by a given set of criteria.  This can be used to make decisions
 	* as to whether a query based on those rows will complete in an acceptable amount of time.
@@ -182,7 +182,7 @@
 	*@return the number of rows included by the criteria.
 	*/
 	public long countHistoryRows(String connectionName, FilterCriteria criteria)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Generate a report, listing the start time, activity count, and identifier bucket, given
 	* a time slice (interval) size.
@@ -202,7 +202,7 @@
 	*/
 	public IResultSet genHistoryActivityCount(String connectionName, FilterCriteria criteria, SortOrder sort, BucketDescription idBucket,
 		long interval, int startRow, int maxRowCount)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Generate a report, listing the start time, bytes processed, and identifier bucket, given
 	* a time slice (interval) size.
@@ -222,7 +222,7 @@
 	*/
 	public IResultSet genHistoryByteCount(String connectionName, FilterCriteria criteria, SortOrder sort, BucketDescription idBucket,
 		long interval, int startRow, int maxRowCount)
-		throws MetacartaException;
+		throws LCFException;
 
 
 	/** Generate a report, listing the result bucket and identifier bucket.
@@ -241,7 +241,7 @@
 	*/
 	public IResultSet genHistoryResultCodes(String connectionName, FilterCriteria criteria, SortOrder sort,
 		BucketDescription resultCodeBucket, BucketDescription idBucket, int startRow, int maxRowCount)
-		throws MetacartaException;
+		throws LCFException;
 
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnector.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnector.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnector.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IRepositoryConnector.java Wed Feb 17 15:57:27 2010
@@ -24,7 +24,7 @@
 import java.io.*;
 import java.util.*;
 
-/** This interface describes an instance of a connection between a repository and Metacarta's
+/** This interface describes an instance of a connection between a repository and LCF's
 * standard "pull" ingestion agent.
 *
 * Each instance of this interface is used in only one thread at a time.  Connection Pooling
@@ -97,7 +97,7 @@
 	*@param threadContext is the current thread context.
 	*/
 	public void install(IThreadContext threadContext)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Uninstall the connector.
 	* This method is called to remove persistent storage for the connector, such as database tables etc.
@@ -105,7 +105,7 @@
 	*@param threadContext is the current thread context.
 	*/
 	public void deinstall(IThreadContext threadContext)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Return the list of activities that this connector supports (i.e. writes into the log).
 	*@return the list.
@@ -139,18 +139,18 @@
 	*@return the connection's status as a displayable string.
 	*/
 	public String check()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** This method is periodically called for all connectors that are connected but not
 	* in active use.
 	*/
 	public void poll()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Close the connection.  Call this before discarding the repository connector.
 	*/
 	public void disconnect()
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Clear out any state information specific to a given thread.
 	* This method is called when this object is returned to the connection pool.
@@ -207,7 +207,7 @@
 	*/
 	public void addSeedDocuments(ISeedingActivity activities, DocumentSpecification spec,
 		long startTime, long endTime, int jobMode)
-		throws MetacartaException, ServiceInterruption;
+		throws LCFException, ServiceInterruption;
 
 	/** Get document versions given an array of document identifiers.
 	* This method is called for EVERY document that is considered. It is
@@ -228,7 +228,7 @@
 	*/
 	public String[] getDocumentVersions(String[] documentIdentifiers, String[] oldVersions, IVersionActivity activities,
 		DocumentSpecification spec, int jobMode, boolean usesDefaultAuthority)
-		throws MetacartaException, ServiceInterruption;
+		throws LCFException, ServiceInterruption;
 
 	/** Process a set of documents.
 	* This is the method that should cause each document to be fetched, processed, and the results either added
@@ -246,7 +246,7 @@
 	*/
 	public void processDocuments(String[] documentIdentifiers, String[] versions, IProcessActivity activities,
 		DocumentSpecification spec, boolean[] scanOnly, int jobMode)
-		throws MetacartaException, ServiceInterruption;
+		throws LCFException, ServiceInterruption;
 
 	/** Free a set of documents.  This method is called for all documents whose versions have been fetched using
 	* the getDocumentVersions() method, including those that returned null versions.  It may be used to free resources
@@ -256,7 +256,7 @@
 	*@param versions is the corresponding set of version identifiers (individual identifiers may be null).
 	*/
 	public void releaseDocumentVersions(String[] documentIdentifiers, String[] versions)
-		throws MetacartaException;
+		throws LCFException;
 
 	/** Get the maximum number of documents to amalgamate together into one batch, for this connector.
 	*@return the maximum number. 0 indicates "unlimited".

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ISeedingActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ISeedingActivity.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ISeedingActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/ISeedingActivity.java Wed Feb 17 15:57:27 2010
@@ -46,7 +46,7 @@
         *@param prereqEventNames is the list of prerequisite events required for this document, or null if none.
         */
         public void addSeedDocument(String documentIdentifier, String[] prereqEventNames)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Record a "seed" document identifier.
         * Seeds passed to this method will be loaded into the job's queue at the beginning of the
@@ -62,7 +62,7 @@
         *@param documentIdentifier is the identifier of the document to add to the "pending" queue.
         */
         public void addSeedDocument(String documentIdentifier)
-                throws MetacartaException;
+                throws LCFException;
 
         /** This method receives document identifiers that should be considered part of the seeds, but do not need to be
         * queued for processing at this time.  (This method is used to keep the hopcount tables up to date.)  It is
@@ -76,6 +76,6 @@
         * "pending" queue.
         */
         public void addUnqueuedSeedDocument(String documentIdentifier)
-                throws MetacartaException;
+                throws LCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IVersionActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IVersionActivity.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IVersionActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/IVersionActivity.java Wed Feb 17 15:57:27 2010
@@ -35,7 +35,7 @@
         *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
         */
         public String[] retrieveParentData(String localIdentifier, String dataName)
-                throws MetacartaException;
+                throws LCFException;
 
         /** Retrieve data passed from parents to a specified child document.
         *@param localIdentifier is the document identifier of the document we want the recorded data for.
@@ -43,6 +43,6 @@
         *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
         */
         public CharacterInput[] retrieveParentDataAsFiles(String localIdentifier, String dataName)
-                throws MetacartaException;
+                throws LCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/JobManagerFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/JobManagerFactory.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/JobManagerFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/JobManagerFactory.java Wed Feb 17 15:57:27 2010
@@ -39,15 +39,15 @@
 	*@return the handle.
 	*/
 	public static IJobManager make(IThreadContext threadContext)
-		throws MetacartaException
+		throws LCFException
 	{
 		Object o = threadContext.get(jobManagerName);
 		if (o == null || !(o instanceof IJobManager))
 		{
 			IDBInterface database = DBInterfaceFactory.make(threadContext,
-				Metacarta.getMasterDatabaseName(),
-				Metacarta.getMasterDatabaseUsername(),
-				Metacarta.getMasterDatabasePassword());
+				LCF.getMasterDatabaseName(),
+				LCF.getMasterDatabaseUsername(),
+				LCF.getMasterDatabasePassword());
 
 			o = new org.apache.lcf.crawler.jobs.JobManager(threadContext,database);
 			threadContext.save(jobManagerName,o);

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectionManagerFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectionManagerFactory.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectionManagerFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectionManagerFactory.java Wed Feb 17 15:57:27 2010
@@ -19,7 +19,7 @@
 package org.apache.lcf.crawler.interfaces;
 
 import org.apache.lcf.core.interfaces.*;
-import org.apache.lcf.crawler.system.Metacarta;
+import org.apache.lcf.crawler.system.LCF;
 
 /** Repository connection manager factory.
 */
@@ -39,15 +39,15 @@
 	*@return the handle.
 	*/
 	public static IRepositoryConnectionManager make(IThreadContext tc)
-		throws MetacartaException
+		throws LCFException
 	{
 		Object o = tc.get(objectName);
 		if (o == null || !(o instanceof IRepositoryConnectionManager))
 		{
 			IDBInterface database = DBInterfaceFactory.make(tc,
-				Metacarta.getMasterDatabaseName(),
-				Metacarta.getMasterDatabaseUsername(),
-				Metacarta.getMasterDatabasePassword());
+				LCF.getMasterDatabaseName(),
+				LCF.getMasterDatabaseUsername(),
+				LCF.getMasterDatabasePassword());
 
 			o = new org.apache.lcf.crawler.repository.RepositoryConnectionManager(tc,database);
 			tc.save(objectName,o);

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectorFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectorFactory.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectorFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/RepositoryConnectorFactory.java Wed Feb 17 15:57:27 2010
@@ -45,7 +45,7 @@
 	*@param className is the class name.
 	*/
 	public static void install(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector connector = getConnectorNoCheck(className);
 		connector.install(threadContext);
@@ -55,7 +55,7 @@
 	*@param className is the class name.
 	*/
 	public static void deinstall(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector connector = getConnectorNoCheck(className);
 		connector.deinstall(threadContext);
@@ -66,7 +66,7 @@
 	*@return the list of activities.
 	*/
 	public static String[] getActivitiesList(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector connector = getConnector(threadContext, className);
 		if (connector == null)
@@ -81,7 +81,7 @@
 	*@return the list of link types, in sorted order.
 	*/
 	public static String[] getRelationshipTypes(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector connector = getConnector(threadContext, className);
 		if (connector == null)
@@ -96,7 +96,7 @@
 	*@return the folder string.
 	*/
 	public static String getJSPFolder(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector connector = getConnector(threadContext, className);
 		if (connector == null)
@@ -109,7 +109,7 @@
 	*@return the connector operating model, as specified in IRepositoryConnector.
 	*/
 	public static int getConnectorModel(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector connector = getConnector(threadContext, className);
 		if (connector == null)
@@ -122,7 +122,7 @@
 	*@return the instance.
 	*/
 	public static IRepositoryConnector getConnectorNoCheck(String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		try
 		{
@@ -133,7 +133,7 @@
 			Object[] arguments = new Object[0];
 			Object o = c.newInstance(arguments);
 			if (!(o instanceof IRepositoryConnector))
-				throw new MetacartaException("Class '"+className+"' does not implement IRepositoryConnector.");
+				throw new LCFException("Class '"+className+"' does not implement IRepositoryConnector.");
 			return (IRepositoryConnector)o;
 		}
 		catch (InvocationTargetException e)
@@ -142,42 +142,42 @@
 			if (z instanceof Error)
 				throw (Error)z;
 			else
-				throw (MetacartaException)z;
+				throw (LCFException)z;
 		}
 		catch (ClassNotFoundException e)
 		{
-			throw new MetacartaException("No class implementing IRepositoryConnector called '"+
+			throw new LCFException("No class implementing IRepositoryConnector called '"+
 				className+"'.",
 				e);
 		}
 		catch (NoSuchMethodException e)
 		{
-			throw new MetacartaException("No appropriate constructor for IRepositoryConnector implementation '"+
+			throw new LCFException("No appropriate constructor for IRepositoryConnector implementation '"+
 				className+"'.  Need xxx(ConfigParams).",
 				e);
 		}
 		catch (SecurityException e)
 		{
-			throw new MetacartaException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 		catch (IllegalAccessException e)
 		{
-			throw new MetacartaException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 		catch (IllegalArgumentException e)
 		{
-			throw new MetacartaException("Shouldn't happen!!!",e);
+			throw new LCFException("Shouldn't happen!!!",e);
 		}
 		catch (InstantiationException e)
 		{
-			throw new MetacartaException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 		catch (ExceptionInInitializerError e)
 		{
-			throw new MetacartaException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 
@@ -188,7 +188,7 @@
 	*@return the instance.
 	*/
 	protected static IRepositoryConnector getConnector(IThreadContext threadContext, String className)
-		throws MetacartaException
+		throws LCFException
 	{
 		IConnectorManager connMgr = ConnectorManagerFactory.make(threadContext);
 		if (connMgr.isInstalled(className) == false)
@@ -203,7 +203,7 @@
 			Object[] arguments = new Object[0];
 			Object o = c.newInstance(arguments);
 			if (!(o instanceof IRepositoryConnector))
-				throw new MetacartaException("Class '"+className+"' does not implement IRepositoryConnector.");
+				throw new LCFException("Class '"+className+"' does not implement IRepositoryConnector.");
 			return (IRepositoryConnector)o;
 		}
 		catch (InvocationTargetException e)
@@ -212,7 +212,7 @@
 			if (z instanceof Error)
 				throw (Error)z;
 			else
-				throw (MetacartaException)z;
+				throw (LCFException)z;
 		}
 		catch (ClassNotFoundException e)
 		{
@@ -221,38 +221,38 @@
 			if (connMgr.isInstalled(className) == false)
 				return null;
 
-			throw new MetacartaException("No class implementing IRepositoryConnector called '"+
+			throw new LCFException("No class implementing IRepositoryConnector called '"+
 				className+"'.",
 				e);
 		}
 		catch (NoSuchMethodException e)
 		{
-			throw new MetacartaException("No appropriate constructor for IRepositoryConnector implementation '"+
+			throw new LCFException("No appropriate constructor for IRepositoryConnector implementation '"+
 				className+"'.  Need xxx(ConfigParams).",
 				e);
 		}
 		catch (SecurityException e)
 		{
-			throw new MetacartaException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 		catch (IllegalAccessException e)
 		{
-			throw new MetacartaException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 		catch (IllegalArgumentException e)
 		{
-			throw new MetacartaException("Shouldn't happen!!!",e);
+			throw new LCFException("Shouldn't happen!!!",e);
 		}
 		catch (InstantiationException e)
 		{
-			throw new MetacartaException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 		catch (ExceptionInInitializerError e)
 		{
-			throw new MetacartaException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
+			throw new LCFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
 				e);
 		}
 
@@ -263,7 +263,7 @@
 	*/
 	public static IRepositoryConnector[] grabMultiple(IThreadContext threadContext,
 		String[] orderingKeys, String[] classNames, ConfigParams[] configInfos, int[] maxPoolSizes)
-		throws MetacartaException
+		throws LCFException
 	{
 		IRepositoryConnector[] rval = new IRepositoryConnector[classNames.length];
 		HashMap orderMap = new HashMap();
@@ -271,7 +271,7 @@
 		while (i < orderingKeys.length)
 		{
 		        if (orderMap.get(orderingKeys[i]) != null)
-			    throw new MetacartaException("Found duplicate order key");
+			    throw new LCFException("Found duplicate order key");
 			orderMap.put(orderingKeys[i],new Integer(i));
 			i++;
 		}
@@ -300,13 +300,13 @@
 					{
 						release(rval[index]);
 					}
-					catch (MetacartaException e2)
+					catch (LCFException e2)
 					{
 					}
 				}
-				if (e instanceof MetacartaException)
+				if (e instanceof LCFException)
 				{
-					throw (MetacartaException)e;
+					throw (LCFException)e;
 				}
 				throw (Error)e;
 			}
@@ -324,7 +324,7 @@
 	*/
 	public static IRepositoryConnector grab(IThreadContext threadContext,
 		String className, ConfigParams configInfo, int maxPoolSize)
-		throws MetacartaException
+		throws LCFException
 	{
 		// We want to get handles off the pool and use them.  But the
 		// handles we fetch have to have the right config information.
@@ -360,10 +360,10 @@
 	/** Release multiple repository connectors.
 	*/
 	public static void releaseMultiple(IRepositoryConnector[] connectors)
-		throws MetacartaException
+		throws LCFException
 	{
 		int i = 0;
-		MetacartaException currentException = null;
+		LCFException currentException = null;
 		while (i < connectors.length)
 		{
 			IRepositoryConnector c = connectors[i++];
@@ -371,7 +371,7 @@
 			{
 				release(c);
 			}
-			catch (MetacartaException e)
+			catch (LCFException e)
 			{
 				if (currentException == null)
 					currentException = e;
@@ -385,7 +385,7 @@
 	*@param connector is the connector to release.
 	*/
 	public static void release(IRepositoryConnector connector)
-		throws MetacartaException
+		throws LCFException
 	{
 		// If the connector is null, skip the release, because we never really got the connector in the first place.
 		if (connector == null)
@@ -412,7 +412,7 @@
 	* This method polls all inactive handles.
 	*/
 	public static void pollAllConnectors(IThreadContext threadContext)
-		throws MetacartaException
+		throws LCFException
 	{
 		// System.out.println("Pool stats:");
 		
@@ -438,7 +438,7 @@
 	*@param threadContext is the local thread context.
 	*/
 	public static void closeAllConnectors(IThreadContext threadContext)
-		throws MetacartaException
+		throws LCFException
 	{
 		// Go through the whole pool and clean it out
 		synchronized (poolHash)
@@ -546,7 +546,7 @@
 		*@return the connector, or null if no connector could be connected.
 		*/
 		public synchronized IRepositoryConnector getConnector(IThreadContext threadContext)
-			throws MetacartaException
+			throws LCFException
 		{
 			while (numFree == 0)
 			{
@@ -556,7 +556,7 @@
 				}
 				catch (InterruptedException e)
 				{
-					throw new MetacartaException("Interrupted: "+e.getMessage(),e,MetacartaException.INTERRUPTED);
+					throw new LCFException("Interrupted: "+e.getMessage(),e,LCFException.INTERRUPTED);
 				}
 			}
 
@@ -579,7 +579,7 @@
 					Object[] arguments = new Object[0];
 					Object o = c.newInstance(arguments);
 					if (!(o instanceof IRepositoryConnector))
-						throw new MetacartaException("Class '"+className+"' does not implement IRepositoryConnector.");
+						throw new LCFException("Class '"+className+"' does not implement IRepositoryConnector.");
 					rc = (IRepositoryConnector)o;
 					rc.connect(configParams);
 				}
@@ -589,7 +589,7 @@
 					if (z instanceof Error)
 						throw (Error)z;
 					else
-						throw (MetacartaException)z;
+						throw (LCFException)z;
 				}
 				catch (ClassNotFoundException e)
 				{
@@ -599,38 +599,38 @@
 					if (connMgr.isInstalled(className) == false)
 						return null;
 					
-					throw new MetacartaException("No class implementing IRepositoryConnector called '"+
+					throw new LCFException("No class implementing IRepositoryConnector called '"+
 						className+"'.",
 						e);
 				}
 				catch (NoSuchMethodException e)
 				{
-					throw new MetacartaException("No appropriate constructor for IRepositoryConnector implementation '"+
+					throw new LCFException("No appropriate constructor for IRepositoryConnector implementation '"+
 						className+"'.  Need xxx(ConfigParams).",
 						e);
 				}
 				catch (SecurityException e)
 				{
-					throw new MetacartaException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
+					throw new LCFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
 						e);
 				}
 				catch (IllegalAccessException e)
 				{
-					throw new MetacartaException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
+					throw new LCFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
 						e);
 				}
 				catch (IllegalArgumentException e)
 				{
-					throw new MetacartaException("Shouldn't happen!!!",e);
+					throw new LCFException("Shouldn't happen!!!",e);
 				}
 				catch (InstantiationException e)
 				{
-					throw new MetacartaException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
+					throw new LCFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
 						e);
 				}
 				catch (ExceptionInInitializerError e)
 				{
-					throw new MetacartaException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
+					throw new LCFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
 						e);
 				}
 			}
@@ -647,7 +647,7 @@
 		*@param connector is the connector.
 		*/
 		public synchronized void releaseConnector(IRepositoryConnector connector)
-			throws MetacartaException
+			throws LCFException
 		{
 			if (connector == null)
 				return;
@@ -663,7 +663,7 @@
 		/** Notify all free connectors.
 		*/
 		public synchronized void pollAll(IThreadContext threadContext)
-			throws MetacartaException
+			throws LCFException
 		{
 			int i = 0;
 			while (i < stack.size())
@@ -679,7 +679,7 @@
 		/** Release all free connectors.
 		*/
 		public synchronized void releaseAll(IThreadContext threadContext)
-			throws MetacartaException
+			throws LCFException
 		{
 			while (stack.size() > 0)
 			{

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/SortOrder.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/SortOrder.java?rev=911029&r1=911028&r2=911029&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/SortOrder.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/lcf/crawler/interfaces/SortOrder.java Wed Feb 17 15:57:27 2010
@@ -44,7 +44,7 @@
 	/** Constructor from string representation.
 	*/
 	public SortOrder(String rep)
-		throws MetacartaException
+		throws LCFException
 	{
 		ParseBuffer pb = new ParseBuffer(rep);
 		StringBuffer numBuffer = new StringBuffer();
@@ -52,7 +52,7 @@
 		{
 			int x = pb.peekCharAt();
 			if (x == -1)
-				throw new MetacartaException("Unexpected end");
+				throw new LCFException("Unexpected end");
 			char y = (char)x;
 			pb.next();
 			if (y == ':')
@@ -72,7 +72,7 @@
 		}
 		catch (NumberFormatException e)
 		{
-			throw new MetacartaException("Bad number",e);
+			throw new LCFException("Bad number",e);
 		}
 	}
 
@@ -190,25 +190,25 @@
 		}
 
 		public SortSpec(ParseBuffer pb)
-			throws MetacartaException
+			throws LCFException
 		{
 			int x = pb.peekCharAt();
 			if (x == -1)
-				throw new MetacartaException("Unexpected end");
+				throw new LCFException("Unexpected end");
 			char y = (char)x;
 			if (y == '+')
 				this.direction = SORT_ASCENDING;
 			else if (y == '-')
 				this.direction = SORT_DESCENDING;
 			else
-				throw new MetacartaException("Bad direction");
+				throw new LCFException("Bad direction");
 			pb.next();
 			StringBuffer sb = new StringBuffer();
 			while (true)
 			{
 				x = pb.peekCharAt();
 				if (x == -1)
-					throw new MetacartaException("Unexpected end");
+					throw new LCFException("Unexpected end");
 				y = (char)x;
 				pb.next();
 				if (y == '.')



Mime
View raw message