org.objectweb.dream.protocol.messagePassing
Class MessagePassingOverChannelImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.protocol.messagePassing.MessagePassingOverChannelImpl
- All Implemented Interfaces:
- ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, MessagePassingOverChannelAttributeController, MessagePassingProtocol, Protocol, AttributeController, BindingController, LifeCycleController
public class MessagePassingOverChannelImpl
- extends AbstractComponent
- implements MessagePassingProtocol, MessagePassingOverChannelAttributeController
Implementation of a message passing protocol using an underlying
ChannelProtocol
. This protocol manage a cache of lower channel
sessions.
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 |
ID_ANNOUNCEMENT_CHUNK_NAME
public static final String ID_ANNOUNCEMENT_CHUNK_NAME
- Chunk name of
ExportIdentifierChunk
send in first message of newly
opened channel session.
- See Also:
- Constant Field Values
MessagePassingOverChannelImpl
public MessagePassingOverChannelImpl()
export
public MessagePassingOutgoingPush export(IncomingPush incomingPushItf,
Map<String,Object> hints)
throws ExportException
- Description copied from interface:
MessagePassingProtocol
- Creates an access point and returns an interface that can be used to send
messages through it. Messages received on this access point will be passed
to the given
IncomingPush
interface.
- Specified by:
export
in interface MessagePassingProtocol
- Parameters:
incomingPushItf
- the interface on which message received on the
created access point will be passed, may be null
.hints
- additional parameters, can be null
.
- Returns:
- an interface which can be used to send messages through the created
access point
- Throws:
ExportException
- if the export process fails.- See Also:
MessagePassingProtocol.export(IncomingPush, Map)
createExportIdentifier
public ExportIdentifier createExportIdentifier(Map<String,Object> info,
ExportIdentifier[] next)
throws InvalidExportIdentifierException
- Description copied from interface:
Protocol
- Creates a new export identifier with the provided info
- Specified by:
createExportIdentifier
in interface Protocol
- Parameters:
info
- the info used to create the export identifier.next
- the export identifier of the lower level protocols.
- Returns:
- a new export identifier.
- Throws:
InvalidExportIdentifierException
- if the export identifier can't be
created.- See Also:
Protocol.createExportIdentifier(Map,
ExportIdentifier[])
getNbMaxSession
public int getNbMaxSession()
- Description copied from interface:
MessagePassingOverChannelAttributeController
- Returns the number of maximum opened lower session.
- Specified by:
getNbMaxSession
in interface MessagePassingOverChannelAttributeController
- Returns:
- the
nbMaxSession
attribute value. - See Also:
MessagePassingOverChannelAttributeController.getNbMaxSession()
setNbMaxSession
public void setNbMaxSession(int nbMaxSession)
- Description copied from interface:
MessagePassingOverChannelAttributeController
- Sets the
nbMaxSession
attribute value.
- Specified by:
setNbMaxSession
in interface MessagePassingOverChannelAttributeController
- Parameters:
nbMaxSession
- the new nbMaxSession
attribute value.- See Also:
MessagePassingOverChannelAttributeController.setNbMaxSession(int)
listFc
public String[] listFc()
- Specified by:
listFc
in interface BindingController
- See Also:
BindingController.listFc()
bindFc
public void bindFc(String clientItfName,
Object serverItf)
throws NoSuchInterfaceException,
IllegalBindingException,
IllegalLifeCycleException
- Specified by:
bindFc
in interface BindingController
- Overrides:
bindFc
in class AbstractComponent
- Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
- See Also:
BindingController.bindFc(String,
Object)
Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.