Package com.qfs.distribution

Interface IDistributedComponent

All Known Implementing Classes:

DataNode, DistributedActivePivotBase

public interface IDistributedComponent

Object that can communicate with other IDistributedComponent via their IDistributedMessenger.

Author:

ActiveViam

Method Summary

Modifier and Type	Method	Description
IDistributedMessenger	getMessenger()	Returns the messenger associated to this component that is used for communicating with the other instances.
default void	registerDistributedAgent(IDistributedAgent agent)	Register the given agent to the IDistributedMessenger.
default void	startMessenger(IMessengerDefinition messengerDefinition)	Start the getMessenger() if it is the desired behavior.
default void	stopMessenger()	Stop the getMessenger().

Method Details

getMessenger

IDistributedMessenger getMessenger()

Returns the messenger associated to this component that is used for communicating with the other instances.

startMessenger

default void startMessenger(IMessengerDefinition messengerDefinition)
                     throws AgentException

Start the getMessenger() 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 AgentException

Stop the getMessenger().

Throws:

AgentException - if the call fails because of incorrect state

registerDistributedAgent

default void registerDistributedAgent(IDistributedAgent agent)

Register the given agent to the IDistributedMessenger.

Parameters:

agent - the agent to register

See Also:

• IDistributedMessenger.register(IDistributedAgent)