You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2013/12/10 13:41:56 UTC
svn commit: r1549827 -
/manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java
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);
+ }
}