Package it.ozimov.springboot.mail.service.defaultimpl

Class DefaultPersistenceService

java.lang.Object

it.ozimov.springboot.mail.service.defaultimpl.DefaultPersistenceService

All Implemented Interfaces:

PersistenceService

@Service("defaultEmailPersistenceService")
@ConditionalOnExpression("\'${spring.mail.scheduler.enabled:false}\' == \'true\' && \'${spring.mail.scheduler.persistence.enabled:false}\' == \'true\'")
public class DefaultPersistenceService
extends Object
implements PersistenceService

Constructor Summary

Constructors

Constructor	Description
DefaultPersistenceService(@NonNull org.springframework.data.redis.core.StringRedisTemplate orderingTemplate, @NonNull org.springframework.data.redis.core.RedisTemplate<String,EmailSchedulingData> valueTemplate)

Method Summary

Modifier and Type	Method	Description
void	add(@NonNull EmailSchedulingData emailSchedulingData)	Persist the EmailSchedulingData into the persistence service.
void	addAll(@NonNull Collection<EmailSchedulingData> emailSchedulingDataList)	Persist all the EmailSchedulingData contained in the given collection into the persistence service.
protected void	addAllOps(Collection<EmailSchedulingData> emailSchedulingDataList)
protected void	addOps(EmailSchedulingData emailSchedulingData)
Optional<EmailSchedulingData>	get(@NonNull String id)	Retrieve an Optional containing the EmailSchedulingData stored for the given emailSchedulingDataId, if the key exists and a value was found.
Collection<EmailSchedulingData>	getNextBatch(int batchMaxSize)	Retrieves a batch of EmailSchedulingData from the persistence layer, such that up to batchMaxSize instances are returned from a whatsoever priority level.
Collection<EmailSchedulingData>	getNextBatch(int priorityLevel, int batchMaxSize)	Retrieves a batch of EmailSchedulingData from the persistence layer, such that up to batchMaxSize instances are returned from a specific priority level.
protected Collection<EmailSchedulingData>	getNextBatchOps(String orderingKey, int batchMaxSize)
protected EmailSchedulingData	getOps(String id)
boolean	remove(@NonNull String id)	Remove the EmailSchedulingData associated to the given id, returning true if the key was found in the persistence layer, false otherwise.
void	removeAll()	Remove all the EmailSchedulingData in the peristence layer.
void	removeAll(int priorityLevel)	Remove all the EmailSchedulingData associated to the given priority level.
void	removeAll(@NonNull Collection<String> ids)	Remove all the EmailSchedulingData associated to the ids in the given collection.
protected boolean	removeOps(String id)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultPersistenceService

@Autowired
public DefaultPersistenceService(@Qualifier("orderingTemplate") @NonNull
 @NonNull org.springframework.data.redis.core.StringRedisTemplate orderingTemplate,
 @Qualifier("valueTemplate") @NonNull
 @NonNull org.springframework.data.redis.core.RedisTemplate<String,EmailSchedulingData> valueTemplate)

Method Details

add

public void add(@NonNull
 @NonNull EmailSchedulingData emailSchedulingData)

Description copied from interface: PersistenceService

Persist the EmailSchedulingData into the persistence service. The key used to store the instance if the one returned by EmailSchedulingData.getId().

Observe that in case of duplicate keys, the new values is used to override the oldest without any warning.

Specified by:

add in interface PersistenceService

Parameters:

emailSchedulingData - the data to be stored.

addOps

protected void addOps(EmailSchedulingData emailSchedulingData)

get

public Optional<EmailSchedulingData> get(@NonNull
 @NonNull String id)

Description copied from interface: PersistenceService

Retrieve an Optional containing the EmailSchedulingData stored for the given emailSchedulingDataId, if the key exists and a value was found.

In case of no value forund the the given key, an empty Optional is returned.

Specified by:

get in interface PersistenceService

Parameters:

id - the emailSchedulingDataId used to store an EmailSchedulingData.

Returns:

an optional containing the scheduling data of an email if any was found for the given emailSchedulingDataId; otherwise, an empty optional.

getOps

protected EmailSchedulingData getOps(String id)

remove

public boolean remove(@NonNull
 @NonNull String id)

Description copied from interface: PersistenceService

Remove the EmailSchedulingData associated to the given id, returning true if the key was found in the persistence layer, false otherwise.

Specified by:

remove in interface PersistenceService

Parameters:

id - the id of stored EmailSchedulingData.

Returns:

true if the id exists and the value was successfully removed; false otherwise.

removeOps

protected boolean removeOps(String id)

addAll

public void addAll(@NonNull
 @NonNull Collection<EmailSchedulingData> emailSchedulingDataList)

Description copied from interface: PersistenceService

Persist all the EmailSchedulingData contained in the given collection into the persistence service. The key used to store each the instance if the one returned by EmailSchedulingData.getId().

Observe that in case of duplicate keys, the new values is used to override the oldest without any warning.

Specified by:

addAll in interface PersistenceService

Parameters:

emailSchedulingDataList - collection of EmailSchedulingData to be persisted

addAllOps

protected void addAllOps(Collection<EmailSchedulingData> emailSchedulingDataList)

getNextBatch

public Collection<EmailSchedulingData> getNextBatch(int priorityLevel,
 int batchMaxSize)

Description copied from interface: PersistenceService

Retrieves a batch of EmailSchedulingData from the persistence layer, such that up to batchMaxSize instances are returned from a specific priority level.

If no data is persisted, an empty collection is returned. If less than batchMaxSize are persisted, batchMaxSize are returned.

Specified by:

getNextBatch in interface PersistenceService

Parameters:

priorityLevel - the priority level from which we want to extract the batch.

batchMaxSize - the desired size of the batch.

Returns:

a batch of EmailSchedulingData to be retrieved from the persistence layer.

getNextBatchOps

protected Collection<EmailSchedulingData> getNextBatchOps(String orderingKey,
 int batchMaxSize)

getNextBatch

public Collection<EmailSchedulingData> getNextBatch(int batchMaxSize)

Description copied from interface: PersistenceService

Retrieves a batch of EmailSchedulingData from the persistence layer, such that up to batchMaxSize instances are returned from a whatsoever priority level.

If no data is persisted, an empty collection is returned. If less than batchMaxSize are persisted, batchMaxSize are returned.

Specified by:

getNextBatch in interface PersistenceService

Parameters:

batchMaxSize - the desired size of the batch.

Returns:

a batch of EmailSchedulingData to be retrieved from the persistence layer.

removeAll

public void removeAll()

Description copied from interface: PersistenceService

Remove all the EmailSchedulingData in the peristence layer.

Specified by:

removeAll in interface PersistenceService

removeAll

public void removeAll(int priorityLevel)

Description copied from interface: PersistenceService

Remove all the EmailSchedulingData associated to the given priority level.

Specified by:

removeAll in interface PersistenceService

Parameters:

priorityLevel - the id of the prioroty level that has to be erased.

removeAll

public void removeAll(@NonNull
 @NonNull Collection<String> ids)

Description copied from interface: PersistenceService

Remove all the EmailSchedulingData associated to the ids in the given collection. If for a specific id no key or value was found in the persistence layer, then the remove operation for that id is simply skipped.

Specified by:

removeAll in interface PersistenceService

Parameters:

ids - a collection of ids of stored EmailSchedulingData.