streams-commits mailing list archives

Repository: incubator-streams
Updated Branches:
  refs/heads/STREAMS-168 b8ccf9f68 -> a57646091


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/STREAMS-168
Commit: a576460911464cf260e37886ce840f4e57dd5f30
Parents: b8ccf9f
Author: sblackmon <sblackmon@apache.org>
Authored: Tue Sep 16 14:24:53 2014 -0500
Committer: sblackmon <sblackmon@apache.org>
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);