svn commit: r1784050 - /manifoldcf/trunk/connectors/nulloutput/connector/src/main/java/org/apache/manifoldcf/agents/output/nullconnector/NullConnector.java

[kwright]

Author: kwright
Date: Wed Feb 22 17:59:28 2017
New Revision: 1784050

URL: http://svn.apache.org/viewvc?rev=1784050&view=rev
Log:
Add activity logging information about metadata, since we seem to have a lot of 
trouble with that lately.

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=1784050&r1=1784049&r2=1784050&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
 Wed Feb 22 17:59:28 2017
@@ -136,7 +136,20 @@ public class NullConnector extends org.a
   {
     // Establish a session
     getSession();
-    activities.recordActivity(null,INGEST_ACTIVITY,new 
Long(document.getBinaryLength()),documentURI,"OK",null);
+    final StringBuffer sb = new StringBuffer();
+    final Iterator<String> metadataKeys = document.getFields();
+    boolean needComma = false;
+    while (metadataKeys.hasNext()) {
+      final String key = metadataKeys.next();
+      final String[] values = document.getFieldAsStrings(key);
+      if (needComma) {
+        sb.append(",");
+      } else {
+        needComma = true;
+      }
+      
sb.append("\"").append(key).append("\":").append(Integer.toString(values.length));
+    }
+    activities.recordActivity(null,INGEST_ACTIVITY,new 
Long(document.getBinaryLength()),documentURI,"OK",sb.toString());
     return DOCUMENTSTATUS_ACCEPTED;
   }