de.hybris.platform.catalog.jalo.synchronization

Class LegacySynchronizationPersistenceAdapter

java.lang.Object

de.hybris.platform.catalog.jalo.synchronization.LegacySynchronizationPersistenceAdapter

All Implemented Interfaces:

SynchronizationPersistenceAdapter<Item,ComposedType>

Direct Known Subclasses:

ServiceLayerSynchronizationPersistenceAdapter

public class LegacySynchronizationPersistenceAdapter
extends Object
implements SynchronizationPersistenceAdapter<Item,ComposedType>

Constructor Summary

Constructors

Constructor and Description
LegacySynchronizationPersistenceAdapter(GenericCatalogCopyContext copyContext)

Method Summary

Modifier and Type	Method and Description
protected boolean	canIgnoreItemRemovedException(Item itemToRemove, Throwable exception)
void	clearTransactionsSettings()
Item	create(ComposedType expectedType, Map<String,Object> attributes) Creates an entity of given type, with set of initial attributes
void	disableTransactions()
protected GenericCatalogCopyContext	getCopyContext()
protected void	handleRemovalException(Item itemToRemove, Throwable exception) Override this method in order to rethrow a SynchronizationPersistenceException or RecoverableSynchronizationPersistenceException in certain situation so upper layer can abort or recover during removal.
void	remove(Item entity) Removes a given entity
void	resetUnitOfWork()
protected boolean	shouldRetry(Throwable exception) Determines which exception should we consider as recoverable so upper layer (worker) can react accordingly.
void	update(Item entity, Map.Entry<String,Object> attribute) Updates a given entity with attribute value pair as its part of or other attribute
void	update(Item entity, Map<String,Object> attributes) Updates a given entity with map of attribute at once

Methods inherited from class java.lang.Object

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

Constructor Detail

LegacySynchronizationPersistenceAdapter

public LegacySynchronizationPersistenceAdapter(GenericCatalogCopyContext copyContext)

Method Detail

create

public Item create(ComposedType expectedType,
                   Map<String,Object> attributes)
            throws SynchronizationPersistenceException

Description copied from interface: SynchronizationPersistenceAdapter

Creates an entity of given type, with set of initial attributes

Specified by:

create in interface SynchronizationPersistenceAdapter<Item,ComposedType>

Returns:

an entity of given type.

Throws:

SynchronizationPersistenceException

remove

public void remove(Item entity)
            throws SynchronizationPersistenceException,
                   RecoverableDataAccessException

Description copied from interface: SynchronizationPersistenceAdapter

Removes a given entity

Specified by:

remove in interface SynchronizationPersistenceAdapter<Item,ComposedType>

Throws:

SynchronizationPersistenceException

RecoverableDataAccessException

handleRemovalException

protected void handleRemovalException(Item itemToRemove,
                                      Throwable exception)
                               throws SynchronizationPersistenceException,
                                      RecoverableDataAccessException

Override this method in order to rethrow a SynchronizationPersistenceException or RecoverableSynchronizationPersistenceException in certain situation so upper layer can abort or recover during removal.

Parameters:

itemToRemove -

exception -

Throws:

SynchronizationPersistenceException

RecoverableDataAccessException

shouldRetry

protected boolean shouldRetry(Throwable exception)

Determines which exception should we consider as recoverable so upper layer (worker) can react accordingly.

Parameters:

exception -

Returns:

true if exception is recoverable, otherwise returns false.

canIgnoreItemRemovedException

protected boolean canIgnoreItemRemovedException(Item itemToRemove,
                                                Throwable exception)

update

public void update(Item entity,
                   Map.Entry<String,Object> attribute)
            throws SynchronizationPersistenceException

Description copied from interface: SynchronizationPersistenceAdapter

Updates a given entity with attribute value pair as its part of or other attribute

Specified by:

update in interface SynchronizationPersistenceAdapter<Item,ComposedType>

Throws:

SynchronizationPersistenceException

update

public void update(Item entity,
                   Map<String,Object> attributes)
            throws SynchronizationPersistenceException

Description copied from interface: SynchronizationPersistenceAdapter

Updates a given entity with map of attribute at once

Specified by:

update in interface SynchronizationPersistenceAdapter<Item,ComposedType>

Throws:

SynchronizationPersistenceException

resetUnitOfWork

public void resetUnitOfWork()

Specified by:

resetUnitOfWork in interface SynchronizationPersistenceAdapter<Item,ComposedType>

disableTransactions

public void disableTransactions()

Specified by:

disableTransactions in interface SynchronizationPersistenceAdapter<Item,ComposedType>

clearTransactionsSettings

public void clearTransactionsSettings()

Specified by:

clearTransactionsSettings in interface SynchronizationPersistenceAdapter<Item,ComposedType>

getCopyContext

protected GenericCatalogCopyContext getCopyContext()