@Test public void testGetIgniteCacheDefaultConfTwoFlowFilesNoKey() throws IOException, InterruptedException { getRunner = TestRunners.newTestRunner(getIgniteCache); getRunner.setProperty(GetIgniteCache.IGNITE_CACHE_ENTRY_KEY, "${igniteKey}"); getRunner.assertValid(); properties1.clear(); getRunner.enqueue("".getBytes(),properties1); getRunner.enqueue("".getBytes(),properties1); getIgniteCache.initialize(getRunner.getProcessContext()); getRunner.run(2, false, true); getRunner.assertAllFlowFilesTransferred(GetIgniteCache.REL_FAILURE, 2); List<MockFlowFile> sucessfulFlowFiles = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_SUCCESS); assertEquals(0, sucessfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_FAILURE); assertEquals(2, failureFlowFiles.size()); final MockFlowFile out1 = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_FAILURE).get(0); out1.assertAttributeEquals(GetIgniteCache.IGNITE_GET_FAILED_REASON_ATTRIBUTE_KEY, GetIgniteCache.IGNITE_GET_FAILED_MISSING_KEY_MESSAGE); final MockFlowFile out2 = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_FAILURE).get(1); out2.assertAttributeEquals(GetIgniteCache.IGNITE_GET_FAILED_REASON_ATTRIBUTE_KEY, GetIgniteCache.IGNITE_GET_FAILED_MISSING_KEY_MESSAGE); getRunner.shutdown(); }
@OnScheduled public final void initialize(ProcessContext context) throws ProcessException { super.initializeIgniteCache(context); }
GetIgniteCache extends AbstractIgniteCacheProcessor { @OnScheduled public final void initialize(ProcessContext context) throws ProcessException { super.initializeIgniteCache(context); } }
GetIgniteCache extends AbstractIgniteCacheProcessor { @OnScheduled public final void initialize(ProcessContext context) throws ProcessException { super.initializeIgniteCache(context); }  }
GetIgniteCache extends AbstractIgniteCacheProcessor { @OnScheduled public final void initialize(ProcessContext context) throws ProcessException { super.initializeIgniteCache(context); }  @Override List<PropertyDescriptor> getSupportedPropertyDescriptors(); @OnScheduled final void initialize(ProcessContext context); @Override void onTrigger(final ProcessContext context, final ProcessSession session); }
GetIgniteCache extends AbstractIgniteCacheProcessor { @OnScheduled public final void initialize(ProcessContext context) throws ProcessException { super.initializeIgniteCache(context); }  @Override List<PropertyDescriptor> getSupportedPropertyDescriptors(); @OnScheduled final void initialize(ProcessContext context); @Override void onTrigger(final ProcessContext context, final ProcessSession session); static final String IGNITE_GET_FAILED_REASON_ATTRIBUTE_KEY; static final String IGNITE_GET_FAILED_MISSING_KEY_MESSAGE; static final String IGNITE_GET_FAILED_MISSING_ENTRY_MESSAGE; static final String IGNITE_GET_FAILED_MESSAGE_PREFIX; }