This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit 34f507edc1e6c5a3e380dff05666e24c916fac12 Author: bossenti <[email protected]> AuthorDate: Thu May 6 17:30:58 2021 +0200 [STREAMPIPES-343] remove redundancy --- .../org/apache/streampipes/connect/protocol/set/FileProtocol.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/set/FileProtocol.java b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/set/FileProtocol.java index 062ef49..1a21497 100644 --- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/set/FileProtocol.java +++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/set/FileProtocol.java @@ -97,10 +97,8 @@ public class FileProtocol extends Protocol { SendToPipeline stk = new SendToPipeline(format, adapterPipeline); try { - InputStream in = Request.Get(fileFetchUrl).execute().returnContent().asStream();; + InputStream in = getDataFromEndpoint(); parser.parse(in, stk); - } catch (IOException e) { - e.printStackTrace(); } catch (ParseException e) { logger.error("Error while parsing: " + e.getMessage()); }
