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 java.lang.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(java.util.Set<org.opennms.newts.api.SampleProcessor> processors)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
awaitShutdown(long timeout, java.util.concurrent.TimeUnit unit)
void
shutdown()
void
submit(java.util.Collection<org.opennms.newts.api.Sample> samples)
-
-
-
Method Detail
-
submit
public void submit(java.util.Collection<org.opennms.newts.api.Sample> samples)
- Specified by:
submit
in interfaceorg.opennms.newts.api.SampleProcessorService
-
shutdown
public void shutdown() throws java.lang.InterruptedException
- Specified by:
shutdown
in interfaceorg.opennms.newts.api.SampleProcessorService
- Throws:
java.lang.InterruptedException
-
awaitShutdown
public boolean awaitShutdown(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
- Specified by:
awaitShutdown
in interfaceorg.opennms.newts.api.SampleProcessorService
- Throws:
java.lang.InterruptedException
-
-