Package com.qfs.distribution
Interface IDistributedComponent
-
- All Known Implementing Classes:
DataNode,DistributedActivePivotBase
public interface IDistributedComponentObject that can communicate with otherIDistributedComponentvia theirIDistributedMessenger.- Author:
- ActiveViam
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description IDistributedMessengergetMessenger()Returns the messenger associated to this component that is used for communicating with the otherinstances.default voidregisterDistributedAgent(IDistributedAgent agent)Register the given agent to theIDistributedMessenger.default voidstartMessenger(IMessengerDefinition messengerDefinition)Start thegetMessenger()if it is the desired behavior.default voidstopMessenger()Stop thegetMessenger().
-
-
-
Method Detail
-
getMessenger
IDistributedMessenger getMessenger()
Returns the messenger associated to this component that is used for communicating with the otherinstances.
-
startMessenger
default void startMessenger(IMessengerDefinition messengerDefinition) throws AgentException
Start thegetMessenger()if it is the desired behavior.- Parameters:
messengerDefinition- the definition of the messenger- Throws:
AgentException- if the call fails because of incorrect state- See Also:
IMessengerDefinition.AUTO_START
-
stopMessenger
default void stopMessenger() throws AgentExceptionStop thegetMessenger().- Throws:
AgentException- if the call fails because of incorrect state
-
registerDistributedAgent
default void registerDistributedAgent(IDistributedAgent agent)
Register the given agent to theIDistributedMessenger.- Parameters:
agent- the agent to register- See Also:
IDistributedMessenger.register(IDistributedAgent)
-
-