LaColla.core.components
Class UA

java.lang.Object
  LaColla.core.components.Compo
      LaColla.core.components.UA

public class UA
extends Compo

Field Summary

Fields inherited from class LaColla.core.components.Compo

purgeSessionPeriodicity, timeRemainingBeforeObjectIsResend

Constructor Summary

UA(int listenPort_, int ApiPort, java.util.ArrayList groupIdList, java.lang.String idFilename)

Method Summary

void	connectUA(java.lang.String host, int port, java.lang.String groupId, java.lang.String username, java.lang.String password)
void	connectUA(java.lang.String groupId, java.lang.String username, java.lang.String password)
java.lang.String	createNewGroup(GroupInfo groupInfo, java.util.concurrent.Semaphore sem, InfoConnectedAgent agent)
java.lang.String	createNewGroup(GroupInfo info, java.lang.String newId, java.util.concurrent.Semaphore sem, InfoConnectedAgent agent)
void	disseminateEvent(Event event)
void	doAcceptAuthenticationOfParticipant(Msg msg)
void	doDeleteObject(java.lang.String groupId, java.lang.String objectId)
void	doDisconnectApplication(java.lang.String groupId, java.lang.String userId, java.lang.String aplicName)
void	doEventsAcceptSynchronizationRequest(Msg msg)
void	doEventsRelatedTo(java.lang.String groupId, java.lang.String objectId)
void	doExceptionTask(Msg message)
void	doFinishedTask(Msg message)
void	doGetInfoGroup(java.lang.String userId, java.lang.String groupId, java.lang.String aplicId)
void	doGetInfoMember(java.lang.String memberId, java.lang.String groupId)
void	doGetInfoMemberAck(Msg msg)
void	doGetObject(ObjectLaCOLLA obj, java.lang.String localpath)
void	doGetObjectAck(Msg msg)
void	doInfoGroupAck(Msg msg)
void	doInstantMsg(Msg msg)
void	doNewEvent(Msg msg)
void	doNewGroup(Event evt, java.lang.String username, java.lang.String password)
void	doNewGroup(Msg msg)
void	doNewGroupAck(Msg msg)
void	doNewMember(java.lang.String memberId, java.lang.String groupId, java.lang.String memberInfoId, java.lang.String role, java.lang.String username, java.lang.String password, java.lang.String email)
void	doPresenceAgentAlive(Msg msg)
void	doPresenceAgentDisconnected(Msg msg)
void	doPurgeSession()
void	doPutObject(ObjectLaCOLLA obj)
void	doServiceActivity()
void	doServiceNewIteration(Msg msg)
void	doServiceTimer()
void	doStoppedTask(Msg message)
void	doTaskState(Msg message)
void	doUpdatePresenceInformation(Msg msg)
java.util.concurrent.ScheduledFuture	getActivity()
java.util.ArrayList	getEventsRelatedTo(java.lang.String groupId, java.lang.String objectId)
ServiceActivity	getServiceActivity()
void	getTaskState(java.lang.String idTask, java.lang.String groupId)
UA	getUA()
void	msgEventAck(Msg msg)
void	msgObjectAck(Msg msg)
void	newGroup(java.lang.String userId, java.lang.String groupId, GroupInfo groupInfo)
void	sendInstantMessage(java.lang.String userId, java.lang.String groupId, java.lang.Object message, java.util.ArrayList targetList)
void	setServiceActivity(ServiceActivity serviceActivity)
void	start(java.lang.String host, int port, java.lang.String groupId, java.lang.String username, java.lang.String password, java.lang.String aplicHost, int appPort, TimestampSummary evSummary)
void	stopTask(java.lang.String idTask, java.lang.String groupId)
java.lang.String	submitTask(byte[] xml, java.lang.String groupId)

Methods inherited from class LaColla.core.components.Compo

createNewGroup, createNewGroup, decrementConnectedAgentsTimeBeforeBeingDiscarted, decrementConnectedAgentsTimeBeforeBeingDiscarted, doAcceptPresenceConsistencyRequest, doInvokePresenceConsistencyRequest, doPartitionsAcceptConsistencyRequest, doPartitionsAcceptSynchronizationRequest, doPartitionsInvokeConsistencyRequest, doPartitionsInvokeSynchronizationRequest, doPresenceAreYouAlive, doPresenceNewConnectedAgent, doServiceEventsConsistency, doServiceEventsSynchronization, doServiceObjectsReplicationChecking, doServicePartitionsChecking, doServicePartitionsConsistency, doServicePartitionsSynchronization, doServicePresenceConsistency, getAddress, getConnecting, getEventsConsistency, getEventsSynchronization, getGroupId, getGroups, getHp, getKindOfAgent, getListenPort, getObjectsReplicationChecking, getOwnerId, getPartitionsChecking, getPartitionsConsistency, getPartitionsSynchronization, getPresenceConsistency, getPurge, getSeqNumGroup, getSequenceNumber, getSequenceNumberInfoAgent, getSequenceNumberObjects, getServiceConnecting, getServiceEventsConsistency, getServiceEventsSynchronization, getServiceObjectsReplicationChecking, getServicePartitionsChecking, getServicePartitionsConsistency, getServicePartitionsSynchronization, getServicePresenceConsistency, getServicePurge, getServiceTimer, getSimulationAgentHp, getSimulationTime, getTime, getTimeBeforeSendingAgentAliveMsg, getTimeRemainingBeforeEventIsResend, getTimeRemainingBeforeObjectIsResend, getTimestampLOCALlocation, goMsg_Dest, isSimulation, presenceConsistencySession, sendEventToConnectedUAandRA, sendToEveryAgent, sendToEveryAgent, setAddress, setConnecting, setEventsConsistency, setEventsSynchronization, setGroupId, setHP, setKindOfAgent, setListenPort, setObjectsReplicationChecking, setOwnerId, setPartitionsChecking, setPartitionsConsistency, setPartitionsSynchronization, setPresenceConsistency, setPurge, setSeqNumGroup, setSequenceNumber, setSequenceNumberInfoAgent, setSequenceNumberObjects, setServiceConnecting, setServiceEventsConsistency, setServiceEventsSynchronization, setServiceObjectsReplicationChecking, setServicePartitionsChecking, setServicePartitionsConsistency, setServicePartitionsSynchronization, setServicePresenceConsistency, setServicePurge, setServiceTimer, setTimeBeforeSendingAgentAliveMsg, setTimer, setTimeRemainingBeforeEventIsResend, setTimeRemainingBeforeObjectIsResend, setTimestampLOCALlocation, start

Methods inherited from class java.lang.Object

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

Constructor Detail

UA

public UA(int listenPort_,
          int ApiPort,
          java.util.ArrayList groupIdList,
          java.lang.String idFilename)

Method Detail

start

public void start(java.lang.String host,
                  int port,
                  java.lang.String groupId,
                  java.lang.String username,
                  java.lang.String password,
                  java.lang.String aplicHost,
                  int appPort,
                  TimestampSummary evSummary)

connectUA

public void connectUA(java.lang.String host,
                      int port,
                      java.lang.String groupId,
                      java.lang.String username,
                      java.lang.String password)

connectUA

public final void connectUA(java.lang.String groupId,
                            java.lang.String username,
                            java.lang.String password)

doUpdatePresenceInformation

public void doUpdatePresenceInformation(Msg msg)

doPresenceAgentAlive

public void doPresenceAgentAlive(Msg msg)

Overrides:

doPresenceAgentAlive in class Compo

doPresenceAgentDisconnected

public void doPresenceAgentDisconnected(Msg msg)

Overrides:

doPresenceAgentDisconnected in class Compo

doAcceptAuthenticationOfParticipant

public void doAcceptAuthenticationOfParticipant(Msg msg)

getActivity

public java.util.concurrent.ScheduledFuture getActivity()

getServiceActivity

public ServiceActivity getServiceActivity()

setServiceActivity

public void setServiceActivity(ServiceActivity serviceActivity)

doNewEvent

public void doNewEvent(Msg msg)

msgEventAck

public void msgEventAck(Msg msg)

disseminateEvent

public void disseminateEvent(Event event)

doEventsAcceptSynchronizationRequest

public void doEventsAcceptSynchronizationRequest(Msg msg)

doPurgeSession

public void doPurgeSession()

msgObjectAck

public void msgObjectAck(Msg msg)

doPutObject

public void doPutObject(ObjectLaCOLLA obj)

doGetObject

public void doGetObject(ObjectLaCOLLA obj,
                        java.lang.String localpath)

Parameters:

obj -

doGetObjectAck

public void doGetObjectAck(Msg msg)

doDeleteObject

public void doDeleteObject(java.lang.String groupId,
                           java.lang.String objectId)

doDisconnectApplication

public void doDisconnectApplication(java.lang.String groupId,
                                    java.lang.String userId,
                                    java.lang.String aplicName)

newGroup

public void newGroup(java.lang.String userId,
                     java.lang.String groupId,
                     GroupInfo groupInfo)
              throws NotEnoughResourcesException

Throws:

NotEnoughResourcesException

doNewGroup

public void doNewGroup(Msg msg)

Overrides:

doNewGroup in class Compo

doNewGroup

public void doNewGroup(Event evt,
                       java.lang.String username,
                       java.lang.String password)

createNewGroup

public java.lang.String createNewGroup(GroupInfo groupInfo,
                                       java.util.concurrent.Semaphore sem,
                                       InfoConnectedAgent agent)

createNewGroup

public java.lang.String createNewGroup(GroupInfo info,
                                       java.lang.String newId,
                                       java.util.concurrent.Semaphore sem,
                                       InfoConnectedAgent agent)

doNewGroupAck

public void doNewGroupAck(Msg msg)

doNewMember

public void doNewMember(java.lang.String memberId,
                        java.lang.String groupId,
                        java.lang.String memberInfoId,
                        java.lang.String role,
                        java.lang.String username,
                        java.lang.String password,
                        java.lang.String email)

getUA

public UA getUA()

submitTask

public java.lang.String submitTask(byte[] xml,
                                   java.lang.String groupId)
                            throws TaskException

Throws:

TaskException

getTaskState

public void getTaskState(java.lang.String idTask,
                         java.lang.String groupId)
                  throws TaskException

Throws:

TaskException

stopTask

public void stopTask(java.lang.String idTask,
                     java.lang.String groupId)
              throws TaskException

Throws:

TaskException

doTaskState

public void doTaskState(Msg message)

doFinishedTask

public void doFinishedTask(Msg message)

doStoppedTask

public void doStoppedTask(Msg message)

doExceptionTask

public void doExceptionTask(Msg message)

sendInstantMessage

public void sendInstantMessage(java.lang.String userId,
                               java.lang.String groupId,
                               java.lang.Object message,
                               java.util.ArrayList targetList)
                        throws UndeliverableInstantMessageException

Throws:

UndeliverableInstantMessageException

doInstantMsg

public void doInstantMsg(Msg msg)

doEventsRelatedTo

public void doEventsRelatedTo(java.lang.String groupId,
                              java.lang.String objectId)

getEventsRelatedTo

public java.util.ArrayList getEventsRelatedTo(java.lang.String groupId,
                                              java.lang.String objectId)

doGetInfoGroup

public void doGetInfoGroup(java.lang.String userId,
                           java.lang.String groupId,
                           java.lang.String aplicId)

doInfoGroupAck

public void doInfoGroupAck(Msg msg)

doGetInfoMember

public void doGetInfoMember(java.lang.String memberId,
                            java.lang.String groupId)

doGetInfoMemberAck

public void doGetInfoMemberAck(Msg msg)

doServiceTimer

public void doServiceTimer()

Overrides:

doServiceTimer in class Compo

doServiceNewIteration

public void doServiceNewIteration(Msg msg)

Overrides:

doServiceNewIteration in class Compo

doServiceActivity

public void doServiceActivity()