|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.dream.AbstractComponent
org.objectweb.dream.pump.AbstractPumpSynchronizedImpl
public abstract class AbstractPumpSynchronizedImpl
Abstract implementation of a synchronized Pull/Push pump. This component has
an optional Mutex
client interface that
it uses to synchronize the execution of its run method with other components.
Field Summary | |
---|---|
protected Pull |
inPullItf
|
protected MessageManager |
messageManagerItf
|
protected Mutex |
mutexItf
|
protected Push |
outPushItf
|
protected AbstractTask |
pumpTask
|
protected boolean |
pushNullPolicy
|
protected boolean |
stopOnPullExceptionPolicy
|
protected boolean |
stopOnPushExceptionPolicy
|
Fields inherited from class org.objectweb.dream.AbstractComponent |
---|
bindingLogger, fcNeedAsyncStart, fcState, lifeCycleLogger, logger, weaveableC |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
---|
STARTED, STOPPED |
Constructor Summary | |
---|---|
AbstractPumpSynchronizedImpl()
|
Method Summary | |
---|---|
void |
bindFc(String clientItfName,
Object serverItf)
|
boolean |
getPushNullPolicy()
Returns the PushNullPolicy. |
boolean |
getStopOnPullExceptionPolicy()
Returns the StopOnPullExceptionPolicy. |
boolean |
getStopOnPushExceptionPolicy()
Returns the StopOnPushExceptionPolicy. |
protected Object |
handlePullException(PullException exception)
Handles a PullException occurring when the activity tries to pull a
message. |
protected Object |
handlePushException(Message message,
PushException exception)
Handles a PushException occurring when the activity tries to push a
message. |
String[] |
listFc()
|
void |
setPushNullPolicy(boolean pushNull)
Sets the PushNullPolicy. |
void |
setStopOnPullExceptionPolicy(boolean stopOnPullException)
Sets the StopOnPullExceptionPolicy. |
void |
setStopOnPushExceptionPolicy(boolean stopOnPushException)
Sets the StopOnPushExceptionPolicy. |
Methods inherited from class org.objectweb.dream.AbstractComponent |
---|
beforeFirstStart, bindFc, getFcNeedAsyncStart, getFcState, initComponent, lookupFc, prepareStopFc, setLogger, startFc, stopFc, unbindFc |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Push outPushItf
protected Pull inPullItf
protected Mutex mutexItf
protected MessageManager messageManagerItf
protected boolean pushNullPolicy
protected boolean stopOnPushExceptionPolicy
protected boolean stopOnPullExceptionPolicy
protected AbstractTask pumpTask
Constructor Detail |
---|
public AbstractPumpSynchronizedImpl()
Method Detail |
---|
public boolean getPushNullPolicy()
PumpAttributeController
getPushNullPolicy
in interface PumpAttributeController
PumpAttributeController.getPushNullPolicy()
public void setPushNullPolicy(boolean pushNull)
PumpAttributeController
setPushNullPolicy
in interface PumpAttributeController
pushNull
- the PushNullPolicy.PumpAttributeController.setPushNullPolicy(boolean)
public boolean getStopOnPushExceptionPolicy()
PumpAttributeController
getStopOnPushExceptionPolicy
in interface PumpAttributeController
PumpAttributeController.getStopOnPushExceptionPolicy()
public void setStopOnPushExceptionPolicy(boolean stopOnPushException)
PumpAttributeController
setStopOnPushExceptionPolicy
in interface PumpAttributeController
stopOnPushException
- the StopOnPushExceptionPolicy.PumpAttributeController.setStopOnPushExceptionPolicy(boolean)
public boolean getStopOnPullExceptionPolicy()
PumpAttributeController
getStopOnPullExceptionPolicy
in interface PumpAttributeController
PumpAttributeController.getStopOnPullExceptionPolicy()
public void setStopOnPullExceptionPolicy(boolean stopOnPullException)
PumpAttributeController
setStopOnPullExceptionPolicy
in interface PumpAttributeController
stopOnPullException
- the StopOnPullExceptionPolicy.PumpAttributeController.setStopOnPullExceptionPolicy(boolean)
protected Object handlePushException(Message message, PushException exception)
PushException
occurring when the activity tries to push a
message. This implementation simply deletes the message using message
manger.
message
- the pushed messageexception
- the exception thrown during the push call.protected Object handlePullException(PullException exception)
PullException
occurring when the activity tries to pull a
message.
exception
- the exception thrown during the pull call.public String[] listFc()
listFc
in interface BindingController
BindingController.listFc()
public void bindFc(String clientItfName, Object serverItf) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
bindFc
in interface BindingController
bindFc
in class AbstractComponent
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.bindFc(String,
Object)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |