org.universAAL.ri.gateway

Class Exporter

java.lang.Object

org.universAAL.ri.gateway.Exporter

All Implemented Interfaces:

IBusMemberRegistryListener

public class Exporter
extends Object
implements IBusMemberRegistryListener

Tracks BusMember through the IBusMemberRegistry, when a new BusMember is registered it is checked if it should be exported, through the exporting operation chain, and if it should then it sends all active sessions an import request.
When a new session is created, it has to be notified to the exporter to send the new session all the issued import requests.
There should only be one Exporter per ASG.

Author:

amedrano

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Exporter.NullConcurrentHashMap Helper class that wraps ConcurrentHashMap allowing for null values.

Constructor Summary

Constructors

Constructor and Description
Exporter(ProxyPool pool) Main Constructor.

Method Summary

Modifier and Type	Method and Description
void	activatedSession(Session session) To be called when a new Session is become active.
void	busMemberAdded(BusMember member, IBusMemberRegistry.BusType type) Invoked when a new BusMember is registered in the bus.
void	busMemberRemoved(BusMember member, IBusMemberRegistry.BusType type) Invoked when an existing BusMember is unregistered from the bus. Initiates Import-remove protocol:
boolean	isRemoveExport(String busMemberId, Session session) Called to check (and handle) if the remote Importer is sending a remove request.
boolean	isTracked(String bmURI) Check whether the URI corresponds to a local BusMember (excluding ProxyBusMembers).
void	regParamsAdded(String busMemberID, Resource[] params) Invoked when registration parameters of an existing BusMember are added.
void	regParamsRemoved(String busMemberID, Resource[] params) Invoked when registration parameters of an existing BusMember are removed.
void	stop() Stop all operations.
void	stopedSession(Session session) To be called when a Session is about to be closed, or is disconnected.

Methods inherited from class java.lang.Object

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

Constructor Detail

Exporter

public Exporter(ProxyPool pool)

Main Constructor.

Parameters:

pool - the pool of proxies to use.

Method Detail

activatedSession

public void activatedSession(Session session)

To be called when a new Session is become active. Checks all the possible BusMembers to be exported and checks for each if it should be exported in the new session.

Parameters:

session -

stopedSession

public void stopedSession(Session session)

To be called when a Session is about to be closed, or is disconnected. Checks all the exported proxies and removes all references, stops them if required.
Does not send remove-requests to peers, Importer in peers will be reseted as soon as the connection is lost.

Parameters:

session -

busMemberAdded

public void busMemberAdded(BusMember member,
                           IBusMemberRegistry.BusType type)

Description copied from interface: IBusMemberRegistryListener

Invoked when a new BusMember is registered in the bus.

Specified by:

busMemberAdded in interface IBusMemberRegistryListener

Parameters:

member - newly added bus member

type - type of bus IBusMemberRegistry

busMemberRemoved

public void busMemberRemoved(BusMember member,
                             IBusMemberRegistry.BusType type)

Invoked when an existing BusMember is unregistered from the bus.
Initiates Import-remove protocol:

Specified by:

busMemberRemoved in interface IBusMemberRegistryListener

Parameters:

member - removed bus member

type - type of bus IBusMemberRegistry

regParamsAdded

public void regParamsAdded(String busMemberID,
                           Resource[] params)

Invoked when registration parameters of an existing BusMember are added. Registration parameters can be, for example, ServiceProfiles for ServiceCallees or ContextEventPattern for ContextSubscriber.

Specified by:

regParamsAdded in interface IBusMemberRegistryListener

Parameters:

busMemberID - the ID of the bus member for which the registration parameters have been added.

params - the registration parameters that have been added.

regParamsRemoved

public void regParamsRemoved(String busMemberID,
                             Resource[] params)

Invoked when registration parameters of an existing BusMember are removed. Registration parameters can be, for example, ServiceProfiles for ServiceCallees or ContextEventPattern for ContextSubscriber.

Specified by:

regParamsRemoved in interface IBusMemberRegistryListener

Parameters:

busMemberID - the ID of the bus member for which the registration parameters have been removed.

params - the registration parameters that have been removed.

isRemoveExport

public boolean isRemoveExport(String busMemberId,
                              Session session)

Called to check (and handle) if the remote Importer is sending a remove request.

Parameters:

busMemberId -

session -

Returns:

stop

public void stop()

Stop all operations.

isTracked

public boolean isTracked(String bmURI)

Check whether the URI corresponds to a local BusMember (excluding ProxyBusMembers).

Parameters:

bmURI - the String containing the URI of the BusMember to check.

Returns:

true iif there is a local BusMember that corresponds to bmURI.