T
- typepublic abstract class AbstractEStage<T> extends Object implements EStage<T>
EStage
that implements metering.Constructor and Description |
---|
AbstractEStage(String stageName)
Constructs an abstract estage.
|
Modifier and Type | Method and Description |
---|---|
Meter |
getInMeter()
Gets the input meter of this stage.
|
Meter |
getOutMeter()
Gets the output meter of this stage.
|
boolean |
isClosed()
Check if the stage can still accept messages.
|
String |
toString()
Get human readable representation of the class (used for logging).
|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
onNext
close
public AbstractEStage(String stageName)
stageName
- the stage namepublic Meter getInMeter()
public Meter getOutMeter()
public boolean isClosed()
Copyright © 2017 The Apache Software Foundation. All rights reserved.