org.universAAL.middleware.service.impl

Class ServiceStrategy

java.lang.Object

java.lang.Thread

org.universAAL.middleware.bus.model.BusStrategy

org.universAAL.middleware.service.impl.ServiceStrategy

All Implemented Interfaces:

Runnable

public class ServiceStrategy
extends BusStrategy

This class implements the BusStrategy for the ServiceBus

Author:

mtazari - Saied Tazari, Carsten Stockloew

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected ILocalServiceSearchResultsData	localServiceSearchResults
protected ILocalServicesIndexData	localServicesIndex
protected ILocalWaitingCallersData	localWaitingCallers
protected PeerCard	theCoordinator

Fields inherited from class org.universAAL.middleware.bus.model.BusStrategy

bus, busModule, commModule

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ServiceStrategy(CommunicationModule commModule)

Method Summary

Modifier and Type	Method and Description
protected IServiceStrategyDataFactory	createServiceStrategyDataFactory()
ServiceProfile[]	getAllServiceProfiles(String serviceURI) This method returns all the globally registered Service Profiles for the given service URI
HashMap<String,List<ServiceProfile>>	getAllServiceProfilesWithCalleeIDs(String serviceURI)
void	handle(BusMessage msg, String senderID) Handle the message.
void	injectCall(String callerID, BusMessage call, PeerCard receiver)
protected void	notifyOnFoundCoordinator()
protected void	waitForCoordinatorToBeKnown()

Methods inherited from class org.universAAL.middleware.bus.model.BusStrategy

buildChannelMessage, getBusMember, getLocalBusByName, handleMessage, run, send, setBus, stopThread

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

localWaitingCallers

protected ILocalWaitingCallersData localWaitingCallers

localServicesIndex

protected ILocalServicesIndexData localServicesIndex

localServiceSearchResults

protected ILocalServiceSearchResultsData localServiceSearchResults

theCoordinator

protected PeerCard theCoordinator

Constructor Detail

ServiceStrategy

public ServiceStrategy(CommunicationModule commModule)

Method Detail

createServiceStrategyDataFactory

protected IServiceStrategyDataFactory createServiceStrategyDataFactory()

injectCall

public void injectCall(String callerID,
                       BusMessage call,
                       PeerCard receiver)

handle

public void handle(BusMessage msg,
                   String senderID)

Description copied from class: BusStrategy

Handle the message. This method is different from the handleMessage(), in that handeMessage() handle the message asynchronously, while queuing the messages to preserve the order of the messages. This method is executed synchronously, without any queuing.

Specified by:

handle in class BusStrategy

Parameters:

msg - message

senderID - sender (bus member) ID

See Also:

#handle(BusMessage, String)

waitForCoordinatorToBeKnown

protected void waitForCoordinatorToBeKnown()
                                    throws InterruptedException

Throws:

InterruptedException

notifyOnFoundCoordinator

protected void notifyOnFoundCoordinator()

getAllServiceProfiles

public ServiceProfile[] getAllServiceProfiles(String serviceURI)

This method returns all the globally registered Service Profiles for the given service URI

Parameters:

serviceURI - the URI of the Service whose profiles are returned

Returns:

the service profiles of the given service

getAllServiceProfilesWithCalleeIDs

public HashMap<String,List<ServiceProfile>> getAllServiceProfilesWithCalleeIDs(String serviceURI)