Just added relevant lines here. public static final Relationship SUCCESS = new Relationship.Builder().name("SUCCESS") .description("Success relationship").build(); if (msgText != null) { FlowFile flowFile = session.create(); flowFile = session.write(flowFile, new OutputStreamCallback() { public void process(final OutputStream out) throws IOException { try { out.write(msgText.getText().getBytes()); } catch (Exception e) { e.printStackTrace(); } } }); session.getProvenanceReporter().receive(flowFile, context.getProperty("MyProp").getValue()); session.transfer(flowFile, REL_SUCCESS); } queueConn.close(); session.commit();
... View more
