|
||||||||||
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.multiplexer.PullPushMultiplexerImpl
Implementation of the PullPushMultiplexer
interface. This
multiplexers periodically pulls its inputs according to the parameters given
to the attach method.
Field Summary | |
protected int |
attachmentId
An integer used to generate attachment ids. |
protected ArrayList |
attachments
The registered attachments. |
protected Map |
inputs
An hashtable storing the intputs of this component. |
protected MessageManager |
messageManagerItf
The message manager client interface of this component |
protected Map |
outputs
An hashtable storing the outputs of this component. |
protected SetTimeStamp |
setTimeStamp
The SetTimeStamp client interface of this component. |
Fields inherited from class org.objectweb.dream.AbstractComponent |
bindingLogger, componentDesc, fcState, firstStart, lifeCycleLogger, logger, weaveableC |
Fields inherited from interface org.objectweb.dream.multiplexer.PullPushMultiplexer |
ITF_NAME |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
STARTED, STOPPED |
Constructor Summary | |
PullPushMultiplexerImpl()
Constructor. |
Method Summary | |
Attachment |
attach(String[] inputNames,
Map[] inputContexts,
String[] outputNames,
Map[] outputContexts,
Map parameters)
Attaches a set of inputs to a set of outputs. |
protected void |
beforeFirstStart(Component componentItf)
|
void |
bindFc(String clientItfName,
Object serverItf)
|
void |
detach(Attachment attachment)
Detaches a set of inputs from a set of outputs. |
ArrayList |
getAttachments()
Returns the attachments that have been registered. |
String[] |
listFc()
|
void |
unbindFc(String clientItfName)
|
void |
update(Attachment attachment)
Updates an attachement. |
Methods inherited from class org.objectweb.dream.AbstractComponent |
getFcState, initComponent, lookupFc, setLogger, startFc, stopFc |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected ArrayList attachments
protected Map inputs
protected Map outputs
protected MessageManager messageManagerItf
protected SetTimeStamp setTimeStamp
protected int attachmentId
Constructor Detail |
public PullPushMultiplexerImpl()
Method Detail |
public Attachment attach(String[] inputNames, Map[] inputContexts, String[] outputNames, Map[] outputContexts, Map parameters) throws NoSuchInterfaceException
attach
in interface PullPushMultiplexer
inputNames
- the names of the inputs to be attached. These inputs must
have been previously bound (with the same name) using the
BindingController
interface.inputContexts
- the contexts to be passed when pulling the inputs.outputNames
- the names of the outputs to wich intputs must be
attached. These outputs must have been previously bound (with the
same name) using the BindingController
interface.outputContexts
- the contexts to be passed when pushing the outputs.parameters
- the attachement parameters. The parameters
Map can have the following String
as keys:
Long
that
specifies in how many ms should the attachement be started. (0
means now).Long
that
specifies in how many ms should the attachement be started. (0
means now).Long
that specifies the time to sleep between two pulling of the
attached inputs.Long
that
specifies in how many ms should the attachement be stop. (must be >
startingDate)Attachment
object
NoSuchInterfaceException
- if inputNames or outputNames contains the
name of an interface to which the component has not been bound.PeriodicAttachment
,
PullPushMultiplexer.attach(String[],
Map[], String[], Map[], Map)
public void detach(Attachment attachment)
PullPushMultiplexer
detach
in interface PullPushMultiplexer
attachment
- an attachment returned by attach
PullPushMultiplexer.detach(Attachment)
public void update(Attachment attachment)
PullPushMultiplexer
Attachment
.
update
in interface PullPushMultiplexer
attachment
- an attachment returned by attach
.PullPushMultiplexer.update(Attachment)
public ArrayList getAttachments()
PullPushMultiplexer
getAttachments
in interface PullPushMultiplexer
PullPushMultiplexer.getAttachments()
public void bindFc(String clientItfName, Object serverItf) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
bindFc
in interface BindingController
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.bindFc(String,
Object)
public void unbindFc(String clientItfName) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
unbindFc
in interface BindingController
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.unbindFc(String)
public String[] listFc()
listFc
in interface BindingController
BindingController.listFc()
protected void beforeFirstStart(Component componentItf) throws IllegalLifeCycleException
IllegalLifeCycleException
AbstractComponent.beforeFirstStart(org.objectweb.fractal.api.Component)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |