cgl.narada.service.replay.impl
Class EntityReplayActuatorImpl

java.lang.Object
  extended by cgl.narada.service.replay.EntityReplayActuator
      extended by cgl.narada.service.replay.impl.EntityReplayActuatorImpl

public class EntityReplayActuatorImpl
extends EntityReplayActuator


Method Summary
 void checkIfReplayPossible(int templateId, int entityId)
          Check to see if replay is possible for a given templateId and entityId
 ReplayRequest createReplayRequest(int templateId, int entityId, boolean requestSequencesAndTimestamps)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, boolean requestForTimestamp, long sequenceNumber)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, long[] sequencesToReplay)
          Create a replay request based on the specified constraints
 ReplayRequest createReplayRequest(int templateId, int entityId, long sequenceStart, long sequenceEnd)
          Create a replay request based on the specified constraints
 ReplayRequest createReplayRequest(int templateId, int entityId, long startTimestamp, long endTimestamp, boolean hasTimestampRange)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, long sequenceStart, long sequenceEnd, Profile[] specifiedConstraints)
          Create a replay request based on the specified constraints
 ReplayRequest createReplayRequest(int templateId, int entityId, String replayTopic, long[] sequencesToReplay)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, String replayTopic, long sequenceStart, long sequenceEnd)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, String replayTopic, long startTimestamp, long endTimestamp, boolean replayWithTimestampRange)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, String replayTopic, long sequenceStart, long sequenceEnd, Profile[] specifiedConstraints)
           
 ReplayRequest createReplayRequest(int templateId, int entityId, String replayRequestIdentifier, String replayTopic, boolean hasStartingSequenceAndEndingTimestamp, long startingSequence, long endingTimestamp)
           
static EntityReplayActuator getInstance()
           
 ReplayRequest getReplayRequest(String replayIdentifier)
          Retrieve a previously created replay request
 void initiateReplay(ReplayRequest replayRequest, ReplayServiceListener replayListener)
          Initiate replay based on the create replay request
 void replayToTopic(ReplayRequest replayRequest, ReplayServiceListener replayListener)
           
 void setQosService(QosServiceImpl qosServiceImpl)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInstance

public static EntityReplayActuator getInstance()

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         long[] sequencesToReplay)
                                  throws ServiceException
Create a replay request based on the specified constraints

Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         long sequenceStart,
                                         long sequenceEnd)
                                  throws ServiceException
Create a replay request based on the specified constraints

Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         long sequenceStart,
                                         long sequenceEnd,
                                         Profile[] specifiedConstraints)
                                  throws ServiceException
Create a replay request based on the specified constraints

Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         boolean requestForTimestamp,
                                         long sequenceNumber)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         String replayRequestIdentifier,
                                         String replayTopic,
                                         boolean hasStartingSequenceAndEndingTimestamp,
                                         long startingSequence,
                                         long endingTimestamp)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         String replayTopic,
                                         long startTimestamp,
                                         long endTimestamp,
                                         boolean replayWithTimestampRange)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         long startTimestamp,
                                         long endTimestamp,
                                         boolean hasTimestampRange)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         boolean requestSequencesAndTimestamps)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         String replayTopic,
                                         long[] sequencesToReplay)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         String replayTopic,
                                         long sequenceStart,
                                         long sequenceEnd)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

createReplayRequest

public ReplayRequest createReplayRequest(int templateId,
                                         int entityId,
                                         String replayTopic,
                                         long sequenceStart,
                                         long sequenceEnd,
                                         Profile[] specifiedConstraints)
                                  throws ServiceException
Specified by:
createReplayRequest in class EntityReplayActuator
Throws:
ServiceException

setQosService

public void setQosService(QosServiceImpl qosServiceImpl)
Specified by:
setQosService in class EntityReplayActuator

checkIfReplayPossible

public void checkIfReplayPossible(int templateId,
                                  int entityId)
                           throws ServiceException
Check to see if replay is possible for a given templateId and entityId

Specified by:
checkIfReplayPossible in class EntityReplayActuator
Throws:
ServiceException

getReplayRequest

public ReplayRequest getReplayRequest(String replayIdentifier)
                               throws ServiceException
Retrieve a previously created replay request

Specified by:
getReplayRequest in class EntityReplayActuator
Throws:
ServiceException

initiateReplay

public void initiateReplay(ReplayRequest replayRequest,
                           ReplayServiceListener replayListener)
                    throws ServiceException
Initiate replay based on the create replay request

Specified by:
initiateReplay in class EntityReplayActuator
Throws:
ServiceException

replayToTopic

public void replayToTopic(ReplayRequest replayRequest,
                          ReplayServiceListener replayListener)
                   throws ServiceException
Specified by:
replayToTopic in class EntityReplayActuator
Throws:
ServiceException


For comments and suggestions please send e-mail to The NaradaBrokering Project