Get the InputStream directly, do not unmarshal to String

cefriel · Dec 17, 2019 · 7255810 · 7255810
1 parent c31ec56
commit 7255810
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 7 deletions.
diff --git a/base_converter/src/main/java/it/cefriel/chimera/processor/rdf4j/RMLProcessor.java b/base_converter/src/main/java/it/cefriel/chimera/processor/rdf4j/RMLProcessor.java
@@ -55,7 +55,7 @@ public class RMLProcessor implements Processor{
     public void process(Exchange exchange) throws Exception {
         Repository repo=null;
         Message in = exchange.getIn();
-        String incoming_message = in.getBody(String.class);
+        InputStream incoming_message = in.getBody(InputStream.class);
         String stream_label=null;
 
         // RML Processor configuration
@@ -73,7 +73,7 @@ public void process(Exchange exchange) throws Exception {
         log.info("RML label: "+stream_label);
         repo=exchange.getProperty(ProcessorConstants.CONTEXT_GRAPH, RDFGraph.class).getRepository();
 
-        streamsMap.put("stream://"+stream_label, new ByteArrayInputStream(incoming_message.getBytes()));
+        streamsMap.put("stream://"+stream_label, incoming_message);
 
         // RML mappings execution
         try (RepositoryConnection con = repo.getConnection()) {

diff --git a/base_converter/src/main/java/it/cefriel/chimera/processor/rdf4j/TurtleDataParser.java b/base_converter/src/main/java/it/cefriel/chimera/processor/rdf4j/TurtleDataParser.java
@@ -16,7 +16,6 @@
 
 package it.cefriel.chimera.processor.rdf4j;
 
-import java.io.ByteArrayInputStream;
 import java.io.InputStream;
 
 import org.apache.camel.Exchange;
@@ -41,19 +40,17 @@ public class TurtleDataParser implements Processor{
 	public void process(Exchange exchange) throws Exception {
 		Repository repo=null;
         RDFParser rdfParser = null;
-        InputStream inStream = null;
     	Model model = new LinkedHashModel();
 		ValueFactory vf = SimpleValueFactory.getInstance();
 
 		Message in = exchange.getIn();
-		String input_msg=in.getBody(String.class);
+		InputStream input_msg=in.getBody(InputStream.class);
 		repo=exchange.getProperty(ProcessorConstants.CONTEXT_GRAPH, RDFGraph.class).getRepository();
 
 		try (RepositoryConnection con = repo.getConnection()) {
         	rdfParser=Rio.createParser(RDFFormat.TURTLE);
         	rdfParser.setRDFHandler(new StatementCollector(model));
-        	inStream=new ByteArrayInputStream(input_msg.getBytes());
-        	rdfParser.parse(inStream, "http://www.cefriel.com/knowledgetech");
+        	rdfParser.parse(input_msg, "http://www.cefriel.com/knowledgetech");
 			con.add(model, vf.createIRI("http://www.cefriel.com/knowledgetech"));
 
 		}