|
@ -22,6 +22,8 @@ public class EHRLogProcesser implements Processor {
|
|
|
@Override
|
|
|
public void process(Exchange exchange) throws Exception {
|
|
|
exchange.getOut().setBody("");
|
|
|
exchange.getOut().setHeader("empty", true);
|
|
|
|
|
|
ArrayList arrayList = exchange.getIn().getBody(ArrayList.class);
|
|
|
if (arrayList.size() != 4) {
|
|
|
return;
|
|
@ -78,8 +80,10 @@ public class EHRLogProcesser implements Processor {
|
|
|
objectNode.set("data", dataNode);
|
|
|
|
|
|
String content = objectMapper.writeValueAsString(objectNode);
|
|
|
|
|
|
exchange.getOut().setBody(content);
|
|
|
} catch (JsonParseException e) {
|
|
|
exchange.getOut().setHeader("empty", false);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|