Package net.avcompris.commons3.dao.impl

Class CorrelationDaoInMemory

java.lang.Object
net.avcompris.commons3.dao.impl.AbstractDao
net.avcompris.commons3.dao.impl.CorrelationDaoInMemory
All Implemented Interfaces:
net.avcompris.commons3.dao.CorrelationDao
@Component public final class CorrelationDaoInMemory extends net.avcompris.commons3.dao.impl.AbstractDao implements net.avcompris.commons3.dao.CorrelationDao

  • Nested Class Summary

    Nested classes/interfaces inherited from class net.avcompris.commons3.dao.impl.AbstractDao

    net.avcompris.commons3.dao.impl.AbstractDao.Action<T>

  • Field Summary

    Fields inherited from class net.avcompris.commons3.dao.impl.AbstractDao

    clock

  • Constructor Summary

    Constructors
    Constructor
    Description
    CorrelationDaoInMemory(net.avcompris.commons3.utils.Clock clock)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addCorrelationId(String correlationId)
     
    boolean
    isCorrelationIdValid(String correlationId)
     
    void
    purgeOlderThanSec(int seconds)
     

    Methods inherited from class net.avcompris.commons3.dao.impl.AbstractDao

    retryUntil, retryUntil

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • CorrelationDaoInMemory

      @Autowired public CorrelationDaoInMemory(net.avcompris.commons3.utils.Clock clock)

  • Method Details

    • isCorrelationIdValid

      public boolean isCorrelationIdValid(String correlationId)
      Specified by:
      isCorrelationIdValid in interface net.avcompris.commons3.dao.CorrelationDao

    • addCorrelationId

      public void addCorrelationId(String correlationId) throws SQLException, IOException, net.avcompris.commons3.dao.exception.DuplicateEntityException
      Specified by:
      addCorrelationId in interface net.avcompris.commons3.dao.CorrelationDao
      Throws:
      SQLException
      IOException
      net.avcompris.commons3.dao.exception.DuplicateEntityException

    • purgeOlderThanSec

      public void purgeOlderThanSec(int seconds) throws SQLException, IOException
      Specified by:
      purgeOlderThanSec in interface net.avcompris.commons3.dao.CorrelationDao
      Throws:
      SQLException
      IOException