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.