@Test public void testGetIgniteCacheDefaultConfOneFlowFileWithPlainKey() throws IOException, InterruptedException { getRunner = TestRunners.newTestRunner(getIgniteCache); getRunner.setProperty(GetIgniteCache.IGNITE_CACHE_ENTRY_KEY, "mykey"); getRunner.assertValid(); getRunner.enqueue(new byte[] {}); getIgniteCache.initialize(getRunner.getProcessContext()); getIgniteCache.getIgniteCache().put("mykey", "test".getBytes()); getRunner.run(1, false, true); getRunner.assertAllFlowFilesTransferred(GetIgniteCache.REL_SUCCESS, 1); List<MockFlowFile> getSucessfulFlowFiles = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_SUCCESS); assertEquals(1, getSucessfulFlowFiles.size()); List<MockFlowFile> getFailureFlowFiles = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_FAILURE); assertEquals(0, getFailureFlowFiles.size()); final MockFlowFile getOut = getRunner.getFlowFilesForRelationship(GetIgniteCache.REL_SUCCESS).get(0); getOut.assertContentEquals("test".getBytes()); 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; }