Package org.opennms.netmgt.newts.support

Class SimpleSampleProcessorService

java.lang.Object

org.opennms.netmgt.newts.support.SimpleSampleProcessorService

All Implemented Interfaces:

org.opennms.newts.api.SampleProcessorService

public class SimpleSampleProcessorService
extends Object
implements org.opennms.newts.api.SampleProcessorService

A simple sample processing service that executes the sample processors serially in the caller's thread.

Author:

jwhite

Constructor Summary

Constructors

Constructor	Description
SimpleSampleProcessorService(Set<org.opennms.newts.api.SampleProcessor> processors)

Method Summary

Modifier and Type	Method	Description
boolean	awaitShutdown(long timeout, TimeUnit unit)
void	shutdown()
void	submit(Collection<org.opennms.newts.api.Sample> samples)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleSampleProcessorService

public SimpleSampleProcessorService(Set<org.opennms.newts.api.SampleProcessor> processors)

Method Detail

submit

public void submit(Collection<org.opennms.newts.api.Sample> samples)

Specified by:

submit in interface org.opennms.newts.api.SampleProcessorService

shutdown

public void shutdown()
              throws InterruptedException

Specified by:

shutdown in interface org.opennms.newts.api.SampleProcessorService

Throws:

InterruptedException

awaitShutdown

public boolean awaitShutdown(long timeout,
                             TimeUnit unit)
                      throws InterruptedException

Specified by:

awaitShutdown in interface org.opennms.newts.api.SampleProcessorService

Throws:

InterruptedException