cgl.narada.service.replay.impl
Class EntityReplayActuatorImpl

java.lang.Object
  cgl.narada.service.replay.EntityReplayActuator
      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