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);
+  }
 
 }