org.universAAL.ri.gateway.proxies.importing

Class ProxySCallee

java.lang.Object

org.universAAL.middleware.bus.member.BusMember

org.universAAL.middleware.bus.member.Callee

org.universAAL.middleware.service.ServiceCallee

org.universAAL.ri.gateway.proxies.importing.ProxySCallee

All Implemented Interfaces:

ProxyBusMember

public class ProxySCallee
extends ServiceCallee
implements ProxyBusMember

Represents remote a ServiceCallee, with its subscription parameters synchronized, it is able to get the calls meant for the remote ServiceCallee and send them to the remote proxy which, in time, makes sure a response from the actual ServiceCallee is transmitted back.

Author:

amedrano

Field Summary

Fields inherited from class org.universAAL.middleware.bus.member.BusMember

busResourceURI, owner, theBus

Constructor Summary

Constructors

Constructor and Description
ProxySCallee(ModuleContext context, ServiceProfile[] realizedServices)

Method Summary

Modifier and Type	Method and Description
void	addRemoteProxyReference(BusMemberReference remoteReference) Add a BusMemberReference to the proxy.
void	addSubscriptionParameters(Resource[] newParams) When a update of registration parameters is required.
void	communicationChannelBroken() This abstract method is called for each member of the bus when the bus is being stopped.
String	getBusMemberId() Get the busmemberId.
Collection<BusMemberReference>	getRemoteProxiesReferences() List all current references for this proxy.
Resource[]	getSubscriptionParameters() Get the subscription parameters of the BusMember being proxied by this proxy.
ServiceResponse	handleCall(ServiceCall call) The actual service method of the ServiceCallee.
void	handleMessage(Session session, WrappedBusMessage busMessage) When a session receives a WrappedBusMessage, it delivers it to the ProxyBusMember which its busMemberId matches the WrappedBusMessage's destination.
boolean	isCompatible(Resource[] registrationParameters) Used to check if a ProxyBusMember is capable of assuming the proxy duties of a requested proxy with the given parameters.
void	removeRemoteProxyReference(BusMemberReference remoteReference) Remove a concrete remote proxy.
void	removeRemoteProxyReferences(Session session) Disconnect from all references that use the same session.Does not send Remove message
void	removeSubscriptionParameters(Resource[] newParams) When a update of registration parameters is required.

Methods inherited from class org.universAAL.middleware.service.ServiceCallee

addNewServiceProfiles, addNewServiceProfiles, busDyingOut, getMyID, handleRequest, removeMatchingProfiles

Methods inherited from class org.universAAL.middleware.bus.member.BusMember

close, getComment, getLabel, getType, getURI, setComment, setLabel

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.universAAL.ri.gateway.proxies.ProxyBusMember

close

Constructor Detail

ProxySCallee

public ProxySCallee(ModuleContext context,
                    ServiceProfile[] realizedServices)

Parameters:

context -

realizedServices -

Method Detail

communicationChannelBroken

public void communicationChannelBroken()

This abstract method is called for each member of the bus when the bus is being stopped.

Specified by:

communicationChannelBroken in class ServiceCallee

handleCall

public ServiceResponse handleCall(ServiceCall call)

The actual service method of the ServiceCallee. It is called by the bus whenever there is a call that need to be serviced by this ServiceCallee.

Specified by:

handleCall in class ServiceCallee

Parameters:

call - the call that needs to be serviced.

Returns:

the result of the call execution.

getBusMemberId

public String getBusMemberId()

Description copied from interface: ProxyBusMember

Get the busmemberId.
For imported proxies this ID of the internal busMember of the proxy.
For exported proxies this ID is of the represented BusMember.

Specified by:

getBusMemberId in interface ProxyBusMember

Returns:

addRemoteProxyReference

public void addRemoteProxyReference(BusMemberReference remoteReference)

Add a BusMemberReference to the proxy. This means that from this moment on the remote proxy and the local proxy can (and should) communicate with each other.
A proxy may have more than one remote reference, each time the local proxy is to send a message it should send it to the whole list of remote proxies (list of references), provided for each the outgoing security checks per message is passed.

Specified by:

addRemoteProxyReference in interface ProxyBusMember

Parameters:

remoteReference - The reference to a remote proxy, its busmemberid and the session through which to find it.

removeRemoteProxyReference

public void removeRemoteProxyReference(BusMemberReference remoteReference)

Remove a concrete remote proxy. Does not send Remove message

Specified by:

removeRemoteProxyReference in interface ProxyBusMember

Parameters:

remoteReference - the remote's proxy reference to stop communicating with.

removeRemoteProxyReferences

public void removeRemoteProxyReferences(Session session)

Disconnect from all references that use the same session.Does not send Remove message

Specified by:

removeRemoteProxyReferences in interface ProxyBusMember

Parameters:

session - the session that is to be disconnected.

getRemoteProxiesReferences

public Collection<BusMemberReference> getRemoteProxiesReferences()

List all current references for this proxy.
usually used to check the size, when the size of the set of references is 0 it means that the proxy should be closed and all Java-references so the object can be collected.

Specified by:

getRemoteProxiesReferences in interface ProxyBusMember

Returns:

the set of referneces.

getSubscriptionParameters

public Resource[] getSubscriptionParameters()

Get the subscription parameters of the BusMember being proxied by this proxy.

Specified by:

getSubscriptionParameters in interface ProxyBusMember

Returns:

handleMessage

public void handleMessage(Session session,
                          WrappedBusMessage busMessage)

Description copied from interface: ProxyBusMember

When a session receives a WrappedBusMessage, it delivers it to the ProxyBusMember which its busMemberId matches the WrappedBusMessage's destination. The delivery is received through this method.

Specified by:

handleMessage in interface ProxyBusMember

Parameters:

session - the session through which the message was received.

busMessage - the actual message received.

isCompatible

public boolean isCompatible(Resource[] registrationParameters)

Used to check if a ProxyBusMember is capable of assuming the proxy duties of a requested proxy with the given parameters.
Usually this is just the comparison of arrays of registration parameters

Specified by:

isCompatible in interface ProxyBusMember

Returns:

true if the proxy is compatible with the parameters.

addSubscriptionParameters

public void addSubscriptionParameters(Resource[] newParams)

When a update of registration parameters is required.

Specified by:

addSubscriptionParameters in interface ProxyBusMember

Parameters:

newParams - the new parameters to use.

removeSubscriptionParameters

public void removeSubscriptionParameters(Resource[] newParams)

When a update of registration parameters is required.

Specified by:

removeSubscriptionParameters in interface ProxyBusMember

Parameters:

newParams - the new parameters to use.