Re: Is my custom processor doing too many things? OnTrigger question

[idioma]

Thanks Oleg,
would this be what I want? 

public void onTrigger(final ProcessContext context, final ProcessSession
session) throws ProcessException {

        FlowFile flowFile = session.get();
        if (flowFile == null) return;

        final String userId = context.getProperty(USER_ID).getValue();
        final String password = context.getProperty(PASSWORD).getValue();
        final String http_post_url =
context.getProperty(HTTP_POST_URL).getValue();

        final AtomicReference<String> httpPostRequestHolder = new
AtomicReference<>();
        session.read(flowFile, new InputStreamCallback() {
            @Override
            public void process(InputStream inputStream) throws IOException
{
                StringWriter strWriter = new StringWriter();
                IOUtils.copy(inputStream, strWriter, "UTF-8");
                httpPostRequestHolder.set(userId);
                httpPostRequestHolder.set(password);
                httpPostRequestHolder.set(http_post_url);
            }
        });

        try {
            postHttpRequest(userId, password, source, message,
http_post_url, resource_ids_file_path);
            session.transfer(flowFile, SUCCESS);
        } catch (IllegalArgumentException ex) {
            session.transfer(flowFile, FAILURE);
            ex.printStackTrace();
        }

        flowFile = session.create();
        flowFile = session.write(flowFile, new OutputStreamCallback() {
            @Override
            public void process(OutputStream out) throws IOException {
                out.write(httpPostRequestHolder.get().getBytes());
            }
        });

        session.transfer(flowFile, SUCCESS);

is this the correct way to write out the JSON response?





--
View this message in context: 
http://apache-nifi-developer-list.39713.n7.nabble.com/Is-my-custom-processor-doing-too-many-things-OnTrigger-question-tp9225p9238.html
Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.