class need not be abstract rootDocument is what should exit processor
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/a5764609 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/a5764609 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/a5764609 Branch: refs/heads/master Commit: a576460911464cf260e37886ce840f4e57dd5f30 Parents: b8ccf9f Author: sblackmon <[email protected]> Authored: Tue Sep 16 14:24:53 2014 -0500 Committer: sblackmon <[email protected]> Committed: Tue Sep 16 14:24:53 2014 -0500 ---------------------------------------------------------------------- .../apache/streams/components/http/SimpleHTTPGetProcessor.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/a5764609/streams-components/streams-processor-http/src/main/java/org/apache/streams/components/http/SimpleHTTPGetProcessor.java ---------------------------------------------------------------------- diff --git a/streams-components/streams-processor-http/src/main/java/org/apache/streams/components/http/SimpleHTTPGetProcessor.java b/streams-components/streams-processor-http/src/main/java/org/apache/streams/components/http/SimpleHTTPGetProcessor.java index dec9d03..d74793a 100644 --- a/streams-components/streams-processor-http/src/main/java/org/apache/streams/components/http/SimpleHTTPGetProcessor.java +++ b/streams-components/streams-processor-http/src/main/java/org/apache/streams/components/http/SimpleHTTPGetProcessor.java @@ -40,7 +40,7 @@ import java.util.List; import java.util.Map; import java.util.Properties; -public abstract class SimpleHTTPGetProcessor implements StreamsProcessor { +public class SimpleHTTPGetProcessor implements StreamsProcessor { private final static String STREAMS_ID = "SimpleHTTPGetProcessor"; @@ -152,7 +152,7 @@ public abstract class SimpleHTTPGetProcessor implements StreamsProcessor { try { response = httpclient.execute(httpget); HttpEntity entity = response.getEntity(); - // TODO: handle rate-limiting + // TODO: handle retry if (response.getStatusLine().getStatusCode() == 200 && entity != null) { entityString = EntityUtils.toString(entity); } @@ -181,7 +181,7 @@ public abstract class SimpleHTTPGetProcessor implements StreamsProcessor { ExtensionUtil.addExtension(extensionEntity, this.configuration.getExtension(), extensionFragment); - entry.setDocument(extensionEntity); + entry.setDocument(rootDocument); result.add(entry);
