|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.commons.pipeline.stage.BaseStage org.apache.commons.pipeline.stage.KeyWaitBufferStage
public class KeyWaitBufferStage
Field Summary |
---|
Fields inherited from class org.apache.commons.pipeline.stage.BaseStage |
---|
context |
Constructor Summary | |
---|---|
KeyWaitBufferStage()
Creates a new instance of KeyWaitBufferStage |
Method Summary | |
---|---|
KeyFactory<Object,? extends Object> |
getKeyFactory()
Getter for property keyFactory. |
QueueFactory<Object> |
getQueueFactory()
Getter for property queueFactory. |
void |
init(StageContext context)
This implementation of init() simply stores a reference to the stage context. |
void |
notify(EventObject ev)
Notify this listener of a StageEvent |
void |
process(Object obj)
The only operation performed by this implementation of process() is to feed the specified object to the downstream feeder. |
void |
setKeyFactory(KeyFactory<Object,? extends Object> keyFactory)
Setter for property keyFactory. |
void |
setQueueFactory(QueueFactory<Object> queueFactory)
Setter for property queueFactory. |
Methods inherited from class org.apache.commons.pipeline.stage.BaseStage |
---|
emit, emit, postprocess, preprocess, release |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public KeyWaitBufferStage()
Method Detail |
---|
public void notify(EventObject ev)
StageEventListener
StageEvent
notify
in interface StageEventListener
ev
- The event to be handled. Listeners should gracefully ignore any events that they
do not know how to handle.public void init(StageContext context)
BaseStage
init
in interface Stage
init
in class BaseStage
context
- the StageContext
within which the stage sill be runpublic void process(Object obj) throws StageException
BaseStage
process
in interface Stage
process
in class BaseStage
obj
- Object to be passed to downstream pipeline.
StageException
- an Exception thrown by an overriding implementation should
be wrapped in a StageException
public KeyFactory<Object,? extends Object> getKeyFactory()
public void setKeyFactory(KeyFactory<Object,? extends Object> keyFactory)
keyFactory
- New value of property keyFactory.public QueueFactory<Object> getQueueFactory()
public void setQueueFactory(QueueFactory<Object> queueFactory)
queueFactory
- New value of property queueFactory.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |