com.gigaspaces.internal.cluster.node.impl.handlers

Class ReplicationInExceptionHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.handlers.ReplicationInExceptionHandler

Direct Known Subclasses:

PrimaryBackupReplicationInExceptionHandler

public class ReplicationInExceptionHandler
extends Object

Handles exceptions on consuming replication packets.

Since:

8.0

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
protected String	_spaceName

Constructor Summary

Constructors

Constructor and Description
ReplicationInExceptionHandler(String spaceName, boolean isCentralDB)

Method Summary

Modifier and Type	Method and Description
protected Level	getDefaultExceptionLevel()
void	handleEntryAlreadyInSpaceOnWrite(IReplicationInContext context, IEntryPacket entryPacket)
void	handleEntryLockedByTransactionOnChange(Logger logger, ITemplatePacket entryPacket)
void	handleEntryLockedByTransactionOnTake(Logger logger, IEntryPacket entryPacket)
void	handleEntryLockedByTransactionOnUpdate(Logger logger, IEntryPacket entryPacket)
void	handleEntryNotInSpaceOnChange(Logger logger, ITemplatePacket entryPacket)
void	handleEntryNotInSpaceOnTake(Logger logger, IEntryPacket entryPacket)
void	handleEntryNotInSpaceOnUpdate(Logger logger, IEntryPacket entryPacket, EntryNotInSpaceException ex)
void	handleEntryVersionConflictOnChange(Logger logger, ITemplatePacket entryPacket, EntryVersionConflictException ex)
void	handleEntryVersionConflictOnChange(Logger logger, ITemplatePacket entryPacket, EntryVersionConflictException ex, Level logLevel)
void	handleEntryVersionConflictOnTake(Logger logger, IEntryPacket entryPacket, EntryVersionConflictException ex)
void	handleEntryVersionConflictOnUpdate(Logger logger, IEntryPacket entryPacket, EntryVersionConflictException ex)
void	handleEntryVersionConflictOnUpdate(Logger logger, IEntryPacket entryPacket, EntryVersionConflictException ex, Level logLevel)
void	handleNoClassNameOnTake(Logger logger, String uid)
protected void	logMessage(Logger logger, String operation, String className, String uid, Level logLevel, String symptom)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_spaceName

protected String _spaceName

Constructor Detail

ReplicationInExceptionHandler

public ReplicationInExceptionHandler(String spaceName,
                                     boolean isCentralDB)

Method Detail

handleEntryLockedByTransactionOnTake

public void handleEntryLockedByTransactionOnTake(Logger logger,
                                                 IEntryPacket entryPacket)

handleEntryAlreadyInSpaceOnWrite

public void handleEntryAlreadyInSpaceOnWrite(IReplicationInContext context,
                                             IEntryPacket entryPacket)

handleEntryNotInSpaceOnTake

public void handleEntryNotInSpaceOnTake(Logger logger,
                                        IEntryPacket entryPacket)

handleEntryVersionConflictOnTake

public void handleEntryVersionConflictOnTake(Logger logger,
                                             IEntryPacket entryPacket,
                                             EntryVersionConflictException ex)

handleNoClassNameOnTake

public void handleNoClassNameOnTake(Logger logger,
                                    String uid)

handleEntryLockedByTransactionOnUpdate

public void handleEntryLockedByTransactionOnUpdate(Logger logger,
                                                   IEntryPacket entryPacket)

handleEntryLockedByTransactionOnChange

public void handleEntryLockedByTransactionOnChange(Logger logger,
                                                   ITemplatePacket entryPacket)

handleEntryVersionConflictOnUpdate

public void handleEntryVersionConflictOnUpdate(Logger logger,
                                               IEntryPacket entryPacket,
                                               EntryVersionConflictException ex)

handleEntryVersionConflictOnChange

public void handleEntryVersionConflictOnChange(Logger logger,
                                               ITemplatePacket entryPacket,
                                               EntryVersionConflictException ex)

handleEntryVersionConflictOnUpdate

public void handleEntryVersionConflictOnUpdate(Logger logger,
                                               IEntryPacket entryPacket,
                                               EntryVersionConflictException ex,
                                               Level logLevel)

handleEntryVersionConflictOnChange

public void handleEntryVersionConflictOnChange(Logger logger,
                                               ITemplatePacket entryPacket,
                                               EntryVersionConflictException ex,
                                               Level logLevel)

handleEntryNotInSpaceOnUpdate

public void handleEntryNotInSpaceOnUpdate(Logger logger,
                                          IEntryPacket entryPacket,
                                          EntryNotInSpaceException ex)

handleEntryNotInSpaceOnChange

public void handleEntryNotInSpaceOnChange(Logger logger,
                                          ITemplatePacket entryPacket)

getDefaultExceptionLevel

protected Level getDefaultExceptionLevel()

logMessage

protected void logMessage(Logger logger,
                          String operation,
                          String className,
                          String uid,
                          Level logLevel,
                          String symptom)