| Constructor and Description | 
|---|
HandleDataConsumeErrorPacket(IDataConsumeResult errorResult,
                            String groupName,
                            long errorDataPacketKey)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractDataConsumeErrorResult  | 
class  | 
DataConsumeOkResult
Signal a consume ok result 
 | 
| Modifier and Type | Method and Description | 
|---|---|
IDataConsumeResult | 
ReplicationPacketDataConsumer.consume(IReplicationInContext context,
       IExecutableReplicationPacketData<?> data,
       IReplicationInFacade replicationInFacade,
       IReplicationInFilterCallback inFilterCallback)  | 
IDataConsumeResult | 
BlobstoreReplicationPacketDataConsumer.consume(IReplicationInContext context,
       IExecutableReplicationPacketData<?> data,
       IReplicationInFacade replicationInFacade,
       IReplicationInFilterCallback inFilterCallback)  | 
IDataConsumeResult | 
IReplicationPacketDataConsumer.consume(IReplicationInContext context,
       T data,
       IReplicationInFacade replicationInFacade,
       IReplicationInFilterCallback filterInCallback)
Consumes a  
IReplicationPacketData and delegate the operation is represents to the
 corresponding method at the given IReplicationInFacade | 
IDataConsumeResult | 
IReplicationPacketDataBatchConsumer.consumePendingPackets(IReplicationInBatchContext batchContext,
                     IReplicationInFacade replicationInFacade)
Consume packets which are pending in the provided batch context. 
 | 
IDataConsumeResult | 
ReplicationPacketDataConsumer.consumePendingPackets(IReplicationInBatchContext context,
                     IReplicationInFacade replicationInFacade)  | 
| Modifier and Type | Method and Description | 
|---|---|
AbstractDataConsumeFix | 
ReplicationPacketDataProducer.createFix(IDataConsumeResult errorResult,
         IExecutableReplicationPacketData<?> errorData)  | 
IDataConsumeFix | 
IReplicationPacketDataProducer.createFix(IDataConsumeResult errorResult,
         T errorData)
Creates a fix for the given error result, that fixed should be applied at the corresponding
  
IReplicationPacketDataConsumer | 
boolean | 
DataConsumeOkResult.sameFailure(IDataConsumeResult otherResult)  | 
boolean | 
IDataConsumeResult.sameFailure(IDataConsumeResult otherResult)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
UnknownConsumeErrorResult  | 
class  | 
UnknownEntryLeaseConsumeResult
A consumption error result that is caused when trying to extend entry lease and that lease do no
 exists in the space. 
 | 
class  | 
UnknownNotifyTemplateLeaseConsumeResult
A consumption error result that is caused when trying to extend notify template lease and that
 lease do no exists in the space. 
 | 
class  | 
UnknownTransactionConsumeResult  | 
class  | 
UnknownTypeConsumeResult
A consume error result caused due to  
UnknownTypeException thrown during consumption | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
UnknownNotifyTemplateLeaseConsumeResult.sameFailure(IDataConsumeResult otherResult)  | 
boolean | 
UnknownTransactionConsumeResult.sameFailure(IDataConsumeResult otherResult)  | 
boolean | 
UnknownTypeConsumeResult.sameFailure(IDataConsumeResult otherResult)  | 
boolean | 
UnknownConsumeErrorResult.sameFailure(IDataConsumeResult otherResult)  | 
boolean | 
UnknownEntryLeaseConsumeResult.sameFailure(IDataConsumeResult otherResult)  | 
| Modifier and Type | Method and Description | 
|---|---|
IDataConsumeFix | 
IReplicationProcessLogExceptionHandler.handleException(IDataConsumeResult errorResult,
               IReplicationOrderedPacket packet)  | 
IDataConsumeFix | 
DefaultProcessLogExceptionHandler.handleException(IDataConsumeResult errorResult,
               IReplicationOrderedPacket packet)  | 
static void | 
AbstractSingleFileTargetProcessLog.throwIfRepetitiveError(IDataConsumeResult prevResult,
                      IDataConsumeResult consumeResult)  | 
Copyright © GigaSpaces.