public class CompletePayload {
    final private int status;
    final private Map<String, String> headers;
    final private Object body;
}

    @Producer
    public CompletePayload next() {
        if (!done) {
            done = true;
            return client.buildFixedRecord(client.execute(config));
        }

        return null;
    }

        Job.components() //
                .component("emitter", "REST://Input?" + configStr) //
                .component("out", "test://collector") //
                .connections() //
                .from("emitter") //
                .to("out") //
                .build() //
                .run();
 final List<Record> records = handler.getCollectedData(Record.class);