com.vii.brillien.services.components.util
Class MessageQueue<R>

java.lang.Object
  extended by com.vii.brillien.core.component.AbstractPresence<R>
      extended by com.vii.brillien.core.component.SuperPresence<R>
          extended by com.vii.brillien.services.components.util.MessageQueue<R>
All Implemented Interfaces:
Aspirer<BrillienCommunication,R>, Presence<BrillienCommunication,R>, Progressor, Sensor<BrillienCommunication>, Callable<R>

public class MessageQueue<R>
extends SuperPresence<R>

MessageQueue implementation in Brillien. The entity changes its state in every incoming message inducing a notification to all presence subscribed to this type's state change events


Nested Class Summary
protected  class MessageQueue.DeliveringState
          A special state changing after each incoming message
 
Field Summary
protected  MessageQueue.DeliveringState deliverState
          DeliveringState instance
 
Fields inherited from class com.vii.brillien.core.component.AbstractPresence
actualStates, defaultErrorState, defaultExitState, defaultInitState, flow, future, messageListening, name, needToLog, needToReport, periodical, presenceManager, stateDivision, stateNotifyQueue, states, submited, superUnits, timeMeasure, waitingForInputData, waitingForResponse
 
Fields inherited from interface com.vii.brillien.kernel.axiom.atomic.Presence
CONSONANT, RESIDENT, SPARKLE
 
Constructor Summary
MessageQueue()
           
 
Method Summary
protected  void buildStateStructure()
           
protected  State getDefaultState()
           
 Object processMessage(String message, Object... parameters)
           
 
Methods inherited from class com.vii.brillien.core.component.SuperPresence
getConnection, getConnection, getConnection, getToStringPrefix, log, nativeLog, retrieveConnection
 
Methods inherited from class com.vii.brillien.core.component.AbstractPresence
activateAll, activateCallable, activateMessaging, addState, addSuperUnits, aspirationTimeIsUp, authorizeCall, buildStateSpace, call, changeState, clearSuperUnits, communicationReceived, containsKey, errorReceived, exceptionLog, get, getActualStates, getAspirationTimeMeasure, getFlow, getFlowID, getFlowToReport, getFullName, getMessageProcessorParameterNames, getMessageProcessorParameterTypes, getName, getParameters, getPotentialStates, getPresenceManager, getReference, getReference, getResult, getSharedMessage, getSharing, getSSOPresenceName, getStateDivision, getSubject, getSuperUnits, hasActivity, hasStateMachine, initStateMashine, initStateStructure, innerActivateCallable, innerCall, innerChangeState, invokeMessageProcessor, invokeRequestProcessor, invokeResultProcessor, isAspirationPeriodical, isInExitState, isInState, isInValidStates, isReference, isWaitingForInputData, isWaitingForResponse, panic, passivateAll, passivateCallable, passivateMessaging, plan, presenseChangedState, printErrorStates, registerStateChangeNotification, removeState, removeSuperUnits, report, reset, retrieve, sendAGet, sendAGet, sendDelegatedGet, sendDelegatedGet, sendError, sendGet, sendGet, sendGet, sendGet, sendResponse, sendSet, sendSet, sendUnitAGet, sendUnitAGet, sendUnitDelegatedGet, sendUnitDelegatedGet, sendUnitGet, sendUnitGet, sendUnitGet, sendUnitGet, sendUnitSet, sendUnitSet, setAspirationPeriodical, setAspirationTimeMeasure, setFlow, setFuture, setName, setPresenceManager, setStateDivision, toString, unregisterStateChangeNotification, validate, validateMessage
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

deliverState

protected MessageQueue.DeliveringState deliverState
DeliveringState instance

Constructor Detail

MessageQueue

public MessageQueue()
Method Detail

getDefaultState

protected State getDefaultState()
Overrides:
getDefaultState in class AbstractPresence<R>

buildStateStructure

protected void buildStateStructure()
Overrides:
buildStateStructure in class AbstractPresence<R>

processMessage

public Object processMessage(String message,
                             Object... parameters)
                      throws BrillienException
Overrides:
processMessage in class AbstractPresence<R>
Throws:
BrillienException


Copyright © 2011. All Rights Reserved.