package com.reizes.shiva2.http.extractor;

import com.reizes.shiva2.etl.core.extractor.AbstractExtractor;

public class RestExtractor extends AbstractExtractor {

	@Override
	public Object doProcess(Object input) throws Exception {
		// TODO Auto-generated method stub
		return null;
	}

}

@@ -36,16 +36,103 @@
 actor;%0A%0A
+import java.io.InputStream;%0Aimport java.net.URISyntaxException;%0Aimport java.util.Map;%0A%0A
 import c
@@ -185,16 +185,58 @@
 tractor;
+%0Aimport com.reizes.shiva2.http.RestClient;
 %0A%0Apublic
@@ -284,16 +284,189 @@
 actor %7B%0A
+%09private RestClient client;%0A%09private Map%3CString, String%3E headers;%0A%09%0A%09public RestExtractor(String host) throws URISyntaxException %7B%0A%09%09this.client = new RestClient(host);%0A%09%7D%0A%09
 %0A%09@Overr
@@ -505,13 +505,18 @@
 ect 
-input
+requestUri
 ) th
@@ -538,56 +538,284 @@
 %7B%0A%09%09
-// TODO Auto-generated method stub%0A%09%09return null
+InputStream is = this.client.get((String)requestUri, headers);%0A%09%09%0A%09%09startProcessItem(is);%0A%09%09%0A%09%09is.close();%0A%09%09return requestUri;%0A%09%7D%0A%0A%09public Map%3CString, String%3E getHeaders() %7B%0A%09%09return headers;%0A%09%7D%0A%0A%09public void setHeaders(Map%3CString, String%3E headers) %7B%0A%09%09this.headers = headers
 ;%0A%09%7D

implement default rest extractor