cgl.narada.service.replay
Class EntityReplayActuator

java.lang.Object
  cgl.narada.service.replay.EntityReplayActuator

Direct Known Subclasses:

EntityReplayActuatorImpl

public abstract class EntityReplayActuator
extends Object

Constructor Summary

EntityReplayActuator()

Method Summary

abstract void	checkIfReplayPossible(int templateId, int entityId) Check to see if replay is possible for a given templateId and entityId
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, boolean requestSequencesAndTimestamps)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, boolean requestForTimestamp, long sequenceNumber)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, long[] sequencesToReplay) Create a replay request based on the specified constraints
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, long sequenceStart, long sequenceEnd) Create a replay request based on the specified constraints
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, long startTimestamp, long endTimestamp, boolean hasTimestampRange)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, long sequenceStart, long sequenceEnd, Profile[] specifiedConstraints) Create a replay request based on the specified constraints
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, String replayTopic, long[] sequencesToReplay)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, String replayTopic, long sequenceStart, long sequenceEnd)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, String replayTopic, long startTimestamp, long endTimestamp, boolean replayWithTimestampRange)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, String replayTopic, long sequenceStart, long sequenceEnd, Profile[] specifiedConstraints)
abstract ReplayRequest	createReplayRequest(int templateId, int entityId, String replayRequestIdentifier, String replayTopic, boolean hasStartingSequenceAndEndingTimestamp, long startingSequence, long endingTimestamp)
static EntityReplayActuator	getInstance()
abstract ReplayRequest	getReplayRequest(String replayIdentifier) Retrieve a previously created replay request
abstract void	initiateReplay(ReplayRequest replayRequest, ReplayServiceListener replayListener) Initiate replay based on the create replay request
abstract void	replayToTopic(ReplayRequest replayRequest, ReplayServiceListener replayListener)
abstract void	setQosService(QosServiceImpl qosServiceImpl)

Methods inherited from class java.lang.Object

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

Constructor Detail

EntityReplayActuator

public EntityReplayActuator()

Method Detail

getInstance

public static EntityReplayActuator getInstance()

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  long[] sequencesToReplay)
                                           throws ServiceException

Create a replay request based on the specified constraints

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  long sequenceStart,
                                                  long sequenceEnd)
                                           throws ServiceException

Create a replay request based on the specified constraints

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  long sequenceStart,
                                                  long sequenceEnd,
                                                  Profile[] specifiedConstraints)
                                           throws ServiceException

Create a replay request based on the specified constraints

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  boolean requestForTimestamp,
                                                  long sequenceNumber)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  String replayRequestIdentifier,
                                                  String replayTopic,
                                                  boolean hasStartingSequenceAndEndingTimestamp,
                                                  long startingSequence,
                                                  long endingTimestamp)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  String replayTopic,
                                                  long startTimestamp,
                                                  long endTimestamp,
                                                  boolean replayWithTimestampRange)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  long startTimestamp,
                                                  long endTimestamp,
                                                  boolean hasTimestampRange)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  boolean requestSequencesAndTimestamps)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  String replayTopic,
                                                  long[] sequencesToReplay)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  String replayTopic,
                                                  long sequenceStart,
                                                  long sequenceEnd)
                                           throws ServiceException

Throws:

ServiceException

createReplayRequest

public abstract ReplayRequest createReplayRequest(int templateId,
                                                  int entityId,
                                                  String replayTopic,
                                                  long sequenceStart,
                                                  long sequenceEnd,
                                                  Profile[] specifiedConstraints)
                                           throws ServiceException

Throws:

ServiceException

checkIfReplayPossible

public abstract void checkIfReplayPossible(int templateId,
                                           int entityId)
                                    throws ServiceException

Check to see if replay is possible for a given templateId and entityId

Throws:

ServiceException

getReplayRequest

public abstract ReplayRequest getReplayRequest(String replayIdentifier)
                                        throws ServiceException

Retrieve a previously created replay request

Throws:

ServiceException

initiateReplay

public abstract void initiateReplay(ReplayRequest replayRequest,
                                    ReplayServiceListener replayListener)
                             throws ServiceException

Initiate replay based on the create replay request

Throws:

ServiceException

replayToTopic

public abstract void replayToTopic(ReplayRequest replayRequest,
                                   ReplayServiceListener replayListener)
                            throws ServiceException

Throws:

ServiceException

setQosService

public abstract void setQosService(QosServiceImpl qosServiceImpl)