public class StreamsProviderTaskTest extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.streams.core.StreamsProvider |
mockProvider |
protected ExecutorService |
pool |
Constructor and Description |
---|
StreamsProviderTaskTest() |
Modifier and Type | Method and Description |
---|---|
void |
earlyException() |
void |
flushes() |
protected Queue<org.apache.streams.core.StreamsDatum> |
getQueue(int numElems) |
void |
removeLocalMBeans() |
void |
runNonPerpetual() |
void |
runPerpetual() |
void |
setup() |
void |
stoppable() |
protected void |
verifyNotRunning(StreamsProviderTask task,
Future<?> taskResult) |
protected org.apache.streams.core.StreamsProvider mockProvider
protected ExecutorService pool
public void setup()
public void removeLocalMBeans()
public void runPerpetual()
public void flushes()
protected Queue<org.apache.streams.core.StreamsDatum> getQueue(int numElems)
public void runNonPerpetual()
public void stoppable() throws InterruptedException
InterruptedException
public void earlyException() throws InterruptedException
InterruptedException
protected void verifyNotRunning(StreamsProviderTask task, Future<?> taskResult)
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.