cgl.narada.service.replay
Class EntityReplayActuator

java.lang.Object
  extended by 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)


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