com.crankuptheamps.client
Interface Store.StoreReplayer

Enclosing interface:
Store

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

execute

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
Replay the specified operation.

Parameters:
index - an index that identifies this operation
operation - the operation to replay
topic - a byte array containing the name of the topic for this operation
topicOffset - the offset in the topic array where the topic name begins
topicLength - the length of the topic name
data - a byte array containing the data for this operation
dataOffset - the offset into the data array where the data begins
dataLength - the length of the data
correlationId - the correlation ID for this message
correlationIdOffset - the offset into the correlation ID array where the correlation ID begins
correlationIdLength - the length of the correlation ID
Throws:
DisconnectedException

execute

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
Replay the specified operation.

Parameters:
index - an index that identifies this operation
operation - the operation to replay
topic - a byte array containing the name of the topic for this operation
topicOffset - the offset in the topic array where the topic name begins
topicLength - the length of the topic name
data - a byte array containing the data for this operation
dataOffset - the offset into the data array where the data begins
dataLength - the length of the data
correlationId - the correlation ID for this message
correlationIdOffset - the offset into the correlation ID array where the correlation ID begins
correlationIdLength - the length of the correlation ID
expiration - the expiration to set on the operation
Throws:
DisconnectedException

execute

void execute(long index,
             int operation,
             byte[] topic,
             long topicOffset,
             long topicLength,
             byte[] data,
             long dataOffset,
             long dataLength,
             int expiration,
             CommandId cmdId)
             throws DisconnectedException
Replay the specified operation.

Parameters:
index - an index that identifies this operation
operation - the operation to replay
topic - a byte array containing the name of the topic for this operation
topicOffset - the offset in the topic array where the topic name begins
topicLength - the length of the topic name
data - a byte array containing the data for this operation
dataOffset - the offset into the data array where the data begins
dataLength - the length of the data
expiration - the expiration to set on the operation
cmdId - the commandID to set on the operation
Throws:
DisconnectedException