@Test public void testNoProcessIdDefined() { ProcessInstanceEventBatch batch = new ProcessInstanceEventBatch("http: assertThat(batch.extractRuntimeSource(emptyMap())).isNull(); }
protected String extractRuntimeSource(Map<String, String> metadata) { String processId = metadata.get(ProcessInstanceEventBody.PROCESS_ID_META_DATA); if(processId == null){ return null; } else { return service + "/" + (processId.contains(".") ? processId.substring(processId.lastIndexOf('.') + 1) : processId); } }
ProcessInstanceEventBatch implements EventBatch { protected String extractRuntimeSource(Map<String, String> metadata) { String processId = metadata.get(ProcessInstanceEventBody.PROCESS_ID_META_DATA); if(processId == null){ return null; } else { return service + "/" + (processId.contains(".") ? processId.substring(processId.lastIndexOf('.') + 1) : processId); } } }
ProcessInstanceEventBatch implements EventBatch { protected String extractRuntimeSource(Map<String, String> metadata) { String processId = metadata.get(ProcessInstanceEventBody.PROCESS_ID_META_DATA); if(processId == null){ return null; } else { return service + "/" + (processId.contains(".") ? processId.substring(processId.lastIndexOf('.') + 1) : processId); } } ProcessInstanceEventBatch(String service, Addons addons); }
ProcessInstanceEventBatch implements EventBatch { protected String extractRuntimeSource(Map<String, String> metadata) { String processId = metadata.get(ProcessInstanceEventBody.PROCESS_ID_META_DATA); if(processId == null){ return null; } else { return service + "/" + (processId.contains(".") ? processId.substring(processId.lastIndexOf('.') + 1) : processId); } } ProcessInstanceEventBatch(String service, Addons addons); @Override void append(Object rawEvent); @Override Collection<DataEvent<?>> events(); }
ProcessInstanceEventBatch implements EventBatch { protected String extractRuntimeSource(Map<String, String> metadata) { String processId = metadata.get(ProcessInstanceEventBody.PROCESS_ID_META_DATA); if(processId == null){ return null; } else { return service + "/" + (processId.contains(".") ? processId.substring(processId.lastIndexOf('.') + 1) : processId); } } ProcessInstanceEventBatch(String service, Addons addons); @Override void append(Object rawEvent); @Override Collection<DataEvent<?>> events(); static final String TRACKED; }