Author: kwright
Date: Tue Dec 10 12:41:56 2013
New Revision: 1549827
URL: http://svn.apache.org/r1549827
Log:
Add history logging for job notification
Modified:
manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java
Modified:
manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java
URL:
http://svn.apache.org/viewvc/manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java?rev=1549827&r1=1549826&r2=1549827&view=diff
==============================================================================
---
manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java
(original)
+++
manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java
Tue Dec 10 12:41:56 2013
@@ -35,6 +35,8 @@ public class NullConnector extends org.a
public final static String INGEST_ACTIVITY = "document ingest";
/** Document removal activity */
public final static String REMOVE_ACTIVITY = "document deletion";
+ /** Job notify activity */
+ public final static String JOB_COMPLETE_ACTIVITY = "output notification";
/** Constructor.
*/
@@ -153,5 +155,16 @@ public class NullConnector extends org.a
activities.recordActivity(null,REMOVE_ACTIVITY,null,documentURI,"OK",null);
}
+ /** Notify the connector of a completed job.
+ * This is meant to allow the connector to flush any internal data structures
it has been keeping around, or to tell the output repository that this
+ * is a good time to synchronize things. It is called whenever a job is
either completed or aborted.
+ *@param activities is the handle to an object that the implementer of an
output connector may use to perform operations, such as logging processing
activity.
+ */
+ @Override
+ public void noteJobComplete(IOutputNotifyActivity activities)
+ throws ManifoldCFException, ServiceInterruption
+ {
+ activities.recordActivity(null,JOB_COMPLETE_ACTIVITY,null,"","OK",null);
+ }
}