### Question:
ScrollElasticsearchHttp extends AbstractElasticsearchHttpProcessor { @Override public Set<Relationship> getRelationships() { return relationships; }  @Override Set<Relationship> getRelationships(); @Override final List<PropertyDescriptor> getSupportedPropertyDescriptors(); @OnScheduled void setup(ProcessContext context); @Override void onTrigger(final ProcessContext context, final ProcessSession session); static final Relationship REL_SUCCESS; static final Relationship REL_FAILURE; static final PropertyDescriptor QUERY; static final PropertyDescriptor SCROLL_DURATION; static final PropertyDescriptor INDEX; static final PropertyDescriptor TYPE; static final PropertyDescriptor FIELDS; static final PropertyDescriptor SORT; static final PropertyDescriptor PAGE_SIZE; }### Answer:
@Test public void testScrollElasticsearchOnTriggerWithServerFailNoIncomingFlowFile() throws IOException { ScrollElasticsearchHttpTestProcessor processor = new ScrollElasticsearchHttpTestProcessor(); processor.setStatus(100, "Should fail", 1); runner = TestRunners.newTestRunner(processor); runner.setProperty(AbstractElasticsearchHttpProcessor.ES_URL, "http: runner.setProperty(ScrollElasticsearchHttp.INDEX, "doc"); runner.setProperty(ScrollElasticsearchHttp.TYPE, "status"); runner.setValidateExpressionUsage(true); runner.setProperty(ScrollElasticsearchHttp.QUERY, "${doc_id}"); runner.setIncomingConnection(false); runner.run(1, true, true); processor.getRelationships().forEach(relationship -> runner.assertTransferCount(relationship, 0)); runner.assertTransferCount(ScrollElasticsearchHttp.REL_FAILURE, 0); }
@Test public void testScrollElasticsearchOnTriggerWithServerFailNoIncomingFlowFile() throws IOException { ScrollElasticsearchHttpTestProcessor processor = new ScrollElasticsearchHttpTestProcessor(); processor.setStatus(100, "Should fail", 1); runner = TestRunners.newTestRunner(processor); runner.setProperty(AbstractElasticsearchHttpProcessor.ES_URL, "http: runner.setProperty(ScrollElasticsearchHttp.INDEX, "doc"); runner.setProperty(ScrollElasticsearchHttp.TYPE, "status"); runner.setProperty(ScrollElasticsearchHttp.QUERY, "${doc_id}"); runner.setIncomingConnection(false); runner.run(1, true, true); processor.getRelationships().forEach(relationship -> runner.assertTransferCount(relationship, 0)); runner.assertTransferCount(ScrollElasticsearchHttp.REL_FAILURE, 0); }