org.universAAL.middleware.managers.distributedmw.impl

Class DistributedMWManagerImpl

java.lang.Object

org.universAAL.middleware.managers.distributedmw.impl.DistributedMWManagerImpl

All Implemented Interfaces:

Manager, DistributedBusMemberManager, DistributedLogManager

public class DistributedMWManagerImpl
extends Object
implements DistributedBusMemberManager, DistributedLogManager

Author:

Carsten Stockloew

Field Summary

Fields

Modifier and Type	Field and Description
static ModuleContext	context
static PeerCard	myPeer
static String	NAMESPACE
static SharedObjectConnector	shared

Constructor Summary

Constructors

Constructor and Description
DistributedMWManagerImpl(ModuleContext context, Object[] shareParamsBMLMgmt, Object[] removeParamsBMLMgmt, Object[] shareParamsLLMgmt, Object[] removeParamsLLMgmt, Object[] shareParamsEvtH, Object[] removeParamsEvtH)

Method Summary

Modifier and Type	Method and Description
void	addListener(DistributedBusMemberListener listener, List<PeerCard> nodes) Add a new listener.
void	addListener(DistributedLogListener listener, List<PeerCard> nodes)
void	dispose() Release all the resources
boolean	init() Initialize the Space Manager
void	loadConfigurations(Dictionary configurations) This method sets all the configurations for the SpaceManager
void	removeListener(DistributedBusMemberListener listener, List<PeerCard> nodes) Remove an existing listener.
void	removeListener(DistributedLogListener listener, List<PeerCard> nodes)
static void	sendMessage(Resource r, List<PeerCard> receivers)
static void	sendMessage(Resource r, PeerCard receiver)
static void	sendMessage(Resource r, Set<PeerCard> receivers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NAMESPACE

public static final String NAMESPACE

See Also:

Constant Field Values

myPeer

public static PeerCard myPeer

context

public static ModuleContext context

shared

public static SharedObjectConnector shared

Constructor Detail

DistributedMWManagerImpl

public DistributedMWManagerImpl(ModuleContext context,
                                Object[] shareParamsBMLMgmt,
                                Object[] removeParamsBMLMgmt,
                                Object[] shareParamsLLMgmt,
                                Object[] removeParamsLLMgmt,
                                Object[] shareParamsEvtH,
                                Object[] removeParamsEvtH)

Method Detail

addListener

public void addListener(DistributedLogListener listener,
                        List<PeerCard> nodes)

Specified by:

addListener in interface DistributedLogManager

removeListener

public void removeListener(DistributedLogListener listener,
                           List<PeerCard> nodes)

Specified by:

removeListener in interface DistributedLogManager

addListener

public void addListener(DistributedBusMemberListener listener,
                        List<PeerCard> nodes)

Description copied from interface: DistributedBusMemberManager

Add a new listener.

Specified by:

addListener in interface DistributedBusMemberManager

Parameters:

listener - The callback that is invoked when a change occurs.

nodes - The set of nodes on which the listener should be added. An empty list will subscribe to all nodes, including nodes that will join the space in the future. Null will subscribe to this node only and is equivalent with a list that contains the PeerCard of this node.

removeListener

public void removeListener(DistributedBusMemberListener listener,
                           List<PeerCard> nodes)

Description copied from interface: DistributedBusMemberManager

Remove an existing listener.

Specified by:

removeListener in interface DistributedBusMemberManager

Parameters:

listener - The callback that was registered before with DistributedBusMemberManager.addListener(DistributedBusMemberListener, List).

nodes - The set of nodes on which the listener should be removed. An empty list will unsubscribe from all nodes. Null will unsubscribe from this node only and is equivalent with a list that contains the PeerCard of this node.

loadConfigurations

public void loadConfigurations(Dictionary configurations)

Description copied from interface: Manager

This method sets all the configurations for the SpaceManager

Specified by:

loadConfigurations in interface Manager

Parameters:

configurations - Dictionary of configurations

init

public boolean init()

Description copied from interface: Manager

Initialize the Space Manager

Specified by:

init in interface Manager

Returns:

true if the initialization is completed, false otherwise

dispose

public void dispose()

Description copied from interface: Manager

Release all the resources

Specified by:

dispose in interface Manager

sendMessage

public static void sendMessage(Resource r,
                               Set<PeerCard> receivers)

sendMessage

public static void sendMessage(Resource r,
                               List<PeerCard> receivers)

sendMessage

public static void sendMessage(Resource r,
                               PeerCard receiver)