Author: kwright
Date: Wed May 10 12:39:21 2017
New Revision: 1794716
URL: http://svn.apache.org/viewvc?rev=1794716&view=rev
Log:
Add missing implementations
Modified:
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
Modified:
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
URL:
http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java?rev=1794716&r1=1794715&r2=1794716&view=diff
==============================================================================
---
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
(original)
+++
manifoldcf/branches/CONNECTORS-1424/connectors/contentlimiter/connector/src/main/java/org/apache/manifoldcf/agents/transformation/contentlimiter/ContentLimiter.java
Wed May 10 12:39:21 2017
@@ -85,14 +85,14 @@ public class ContentLimiter extends org.
public boolean checkMimeTypeIndexable(VersionContext outputDescription,
String mimeType, IOutputCheckActivity activities)
throws ManifoldCFException, ServiceInterruption
{
- return true;
+ return activities.checkMimeTypeIndexable(mimeType);
}
@Override
public boolean checkLengthIndexable(VersionContext outputDescription, long
length, IOutputCheckActivity activities)
throws ManifoldCFException, ServiceInterruption {
- // Always true;
- return true;
+ final SpecPacker sp = new SpecPacker(outputDescription.getSpecification());
+ return activities.checkLengthIndexable(Math.min(length, sp.lengthCutoff));
}
/** Add (or replace) a document in the output data store using the connector.
@@ -110,6 +110,8 @@ public class ContentLimiter extends org.
public int addOrReplaceDocumentWithException(String documentURI,
VersionContext outputDescription, RepositoryDocument document, String
authorityNameString, IOutputAddActivity activities)
throws ManifoldCFException, ServiceInterruption, IOException
{
+ final SpecPacker sp = new SpecPacker(outputDescription.getSpecification());
+
InputStream is = null;
DestinationStorage ds = null;
try {
@@ -118,7 +120,6 @@ public class ContentLimiter extends org.
long startTime = System.currentTimeMillis();
String resultCode = "OK";
String description = null;
- SpecPacker sp = new SpecPacker(outputDescription.getSpecification());
if(document.getBinaryLength() > sp.lengthCutoff) {
