### Question:
DataDogReportingTask extends AbstractReportingTask { @Override public void onTrigger(ReportingContext context) { final ProcessGroupStatus status = context.getEventAccess().getControllerStatus(); metricsPrefix = context.getProperty(METRICS_PREFIX).evaluateAttributeExpressions().getValue(); environment = context.getProperty(ENVIRONMENT).evaluateAttributeExpressions().getValue(); statusId = status.getId(); defaultTags = ImmutableMap.of("env", environment, "dataflow_id", statusId); try { updateDataDogTransport(context); } catch (IOException e) { e.printStackTrace(); } updateAllMetricGroups(status); ddMetricRegistryBuilder.getDatadogReporter().report(); }  @OnScheduled void setup(final ConfigurationContext context); @Override void onTrigger(ReportingContext context);  }### Answer:
@Test public void testOnTrigger() throws InitializationException, IOException { DataDogReportingTask dataDogReportingTask = new TestableDataDogReportingTask(); dataDogReportingTask.initialize(initContext); dataDogReportingTask.setup(configurationContext); dataDogReportingTask.onTrigger(context); verify(metricsService, atLeast(1)).getProcessorMetrics(Mockito.<ProcessorStatus>any()); verify(metricsService, atLeast(1)).getJVMMetrics(Mockito.<VirtualMachineMetrics>any()); }