Class JdbcInboundMessageRepository

java.lang.Object

ch.admin.bit.jeap.messageexchange.persistence.JdbcInboundMessageRepository

All Implemented Interfaces:

ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

@Repository
public class JdbcInboundMessageRepository
extends Object
implements ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

Constructor Summary

Constructors

Constructor	Description
JdbcInboundMessageRepository(org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate)

Method Summary

Modifier and Type	Method	Description
boolean	deleteExpiredMessages(int olderThanDays, int limit)
Optional<ch.admin.bit.jeap.messageexchange.domain.InboundMessage>	findByBpIdAndMessageId(String bpId, UUID messageId)
Optional<ch.admin.bit.jeap.messageexchange.domain.InboundMessage>	findLatestByMessageId(UUID messageId)
boolean	updateScanStatusIfPending(UUID messageId, ch.admin.bit.jeap.messageexchange.domain.malwarescan.ScanStatus newScanStatus)
Optional<ch.admin.bit.jeap.messageexchange.domain.InboundMessage>	updateScanStatusReturningPreviousState(UUID messageId, ch.admin.bit.jeap.messageexchange.domain.malwarescan.ScanStatus newScanStatus)
void	upsertScanStatusAndMetadata(ch.admin.bit.jeap.messageexchange.domain.InboundMessage inboundMessage)
void	upsertScanStatusAndMetadataKeepingTerminalStatus(ch.admin.bit.jeap.messageexchange.domain.InboundMessage inboundMessage)

Methods inherited from class Object

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

Constructor Details

JdbcInboundMessageRepository

public JdbcInboundMessageRepository(org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate)

Method Details

findByBpIdAndMessageId

@Transactional(readOnly=true)
public Optional<ch.admin.bit.jeap.messageexchange.domain.InboundMessage> findByBpIdAndMessageId(String bpId,
 UUID messageId)

Specified by:

findByBpIdAndMessageId in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

findLatestByMessageId

@Transactional(readOnly=true)
public Optional<ch.admin.bit.jeap.messageexchange.domain.InboundMessage> findLatestByMessageId(UUID messageId)

Specified by:

findLatestByMessageId in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

updateScanStatusReturningPreviousState

@Transactional
public Optional<ch.admin.bit.jeap.messageexchange.domain.InboundMessage> updateScanStatusReturningPreviousState(UUID messageId,
 ch.admin.bit.jeap.messageexchange.domain.malwarescan.ScanStatus newScanStatus)

Specified by:

updateScanStatusReturningPreviousState in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

updateScanStatusIfPending

@Transactional
public boolean updateScanStatusIfPending(UUID messageId,
 ch.admin.bit.jeap.messageexchange.domain.malwarescan.ScanStatus newScanStatus)

Specified by:

updateScanStatusIfPending in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

upsertScanStatusAndMetadata

@Transactional
public void upsertScanStatusAndMetadata(ch.admin.bit.jeap.messageexchange.domain.InboundMessage inboundMessage)

Specified by:

upsertScanStatusAndMetadata in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

upsertScanStatusAndMetadataKeepingTerminalStatus

@Transactional
public void upsertScanStatusAndMetadataKeepingTerminalStatus(ch.admin.bit.jeap.messageexchange.domain.InboundMessage inboundMessage)

Specified by:

upsertScanStatusAndMetadataKeepingTerminalStatus in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository

deleteExpiredMessages

@Transactional(propagation=REQUIRES_NEW)
public boolean deleteExpiredMessages(int olderThanDays,
 int limit)

Specified by:

deleteExpiredMessages in interface ch.admin.bit.jeap.messageexchange.domain.database.InboundMessageRepository