|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public static interface Store.StoreReplayer
Replay the messages saved in a store. Provided to the
Store.replay(com.crankuptheamps.client.Store.StoreReplayer)
or Store.replaySingle(com.crankuptheamps.client.Store.StoreReplayer, long)
methods
to replay stored operations. The StoreReplayer is responsible for
publishing the operations to AMPS.
Method Summary | |
---|---|
void |
execute(long index,
int operation,
byte[] topic,
long topicOffset,
long topicLength,
byte[] data,
long dataOffset,
long dataLength,
byte[] correlationId,
long correlationIdOffset,
long correlationIdLength)
Replay the specified operation. |
void |
execute(long index,
int operation,
byte[] topic,
long topicOffset,
long topicLength,
byte[] data,
long dataOffset,
long dataLength,
byte[] correlationId,
long correlationIdOffset,
long correlationIdLength,
int expiration)
Replay the specified operation. |
void |
execute(long index,
int operation,
byte[] topic,
long topicOffset,
long topicLength,
byte[] data,
long dataOffset,
long dataLength,
int expiration,
CommandId cmdId)
Replay the specified operation. |
Method Detail |
---|
void execute(long index, int operation, byte[] topic, long topicOffset, long topicLength, byte[] data, long dataOffset, long dataLength, byte[] correlationId, long correlationIdOffset, long correlationIdLength) throws DisconnectedException
index
- an index that identifies this operationoperation
- the operation to replaytopic
- a byte array containing the name of the topic for this operationtopicOffset
- the offset in the topic array where the topic name beginstopicLength
- the length of the topic namedata
- a byte array containing the data for this operationdataOffset
- the offset into the data array where the data beginsdataLength
- the length of the datacorrelationId
- the correlation ID for this messagecorrelationIdOffset
- the offset into the correlation ID array where the correlation ID beginscorrelationIdLength
- the length of the correlation ID
DisconnectedException
void execute(long index, int operation, byte[] topic, long topicOffset, long topicLength, byte[] data, long dataOffset, long dataLength, byte[] correlationId, long correlationIdOffset, long correlationIdLength, int expiration) throws DisconnectedException
index
- an index that identifies this operationoperation
- the operation to replaytopic
- a byte array containing the name of the topic for this operationtopicOffset
- the offset in the topic array where the topic name beginstopicLength
- the length of the topic namedata
- a byte array containing the data for this operationdataOffset
- the offset into the data array where the data beginsdataLength
- the length of the datacorrelationId
- the correlation ID for this messagecorrelationIdOffset
- the offset into the correlation ID array where the correlation ID beginscorrelationIdLength
- the length of the correlation IDexpiration
- the expiration to set on the operation
DisconnectedException
void execute(long index, int operation, byte[] topic, long topicOffset, long topicLength, byte[] data, long dataOffset, long dataLength, int expiration, CommandId cmdId) throws DisconnectedException
index
- an index that identifies this operationoperation
- the operation to replaytopic
- a byte array containing the name of the topic for this operationtopicOffset
- the offset in the topic array where the topic name beginstopicLength
- the length of the topic namedata
- a byte array containing the data for this operationdataOffset
- the offset into the data array where the data beginsdataLength
- the length of the dataexpiration
- the expiration to set on the operationcmdId
- the commandID to set on the operation
DisconnectedException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |