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)
void	save(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

save

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

Specified by:

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

findByBpIdAndMessageId

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

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