@Test public void constructor() { try (PushProcessorPipeline impl = new PushProcessorPipeline(registry, 10, processor)) { assertEquals(10, impl.getIntervalSeconds()); assertSame(registry, impl.getMetricRegistry()); } }
public final int getIntervalSeconds() { return interval_seconds_; }
PushProcessorPipeline extends AbstractProcessor<PushMetricRegistryInstance> implements Runnable { public final int getIntervalSeconds() { return interval_seconds_; } }
PushProcessorPipeline extends AbstractProcessor<PushMetricRegistryInstance> implements Runnable { public final int getIntervalSeconds() { return interval_seconds_; } PushProcessorPipeline(PushMetricRegistryInstance registry, int interval_seconds, List<PushProcessor> processors);  PushProcessorPipeline(PushMetricRegistryInstance registry, int interval_seconds, PushProcessor processor); }
PushProcessorPipeline extends AbstractProcessor<PushMetricRegistryInstance> implements Runnable { public final int getIntervalSeconds() { return interval_seconds_; } PushProcessorPipeline(PushMetricRegistryInstance registry, int interval_seconds, List<PushProcessor> processors);  PushProcessorPipeline(PushMetricRegistryInstance registry, int interval_seconds, PushProcessor processor); @Override final void run(); final int getIntervalSeconds(); void start(boolean daemon, int thread_priority); void start(); void start(boolean daemon); void start(int thread_priority); void start(ScheduledExecutorService ses); ScheduledFuture<?> createTimerTask(ScheduledExecutorService ses); @Override void close(); }
PushProcessorPipeline extends AbstractProcessor<PushMetricRegistryInstance> implements Runnable { public final int getIntervalSeconds() { return interval_seconds_; } PushProcessorPipeline(PushMetricRegistryInstance registry, int interval_seconds, List<PushProcessor> processors);  PushProcessorPipeline(PushMetricRegistryInstance registry, int interval_seconds, PushProcessor processor); @Override final void run(); final int getIntervalSeconds(); void start(boolean daemon, int thread_priority); void start(); void start(boolean daemon); void start(int thread_priority); void start(ScheduledExecutorService ses); ScheduledFuture<?> createTimerTask(ScheduledExecutorService ses); @Override void close();  }