Package ch.admin.bit.jeap.messageexchange.persistence

Class JdbcMessageRepository

java.lang.Object

ch.admin.bit.jeap.messageexchange.persistence.JdbcMessageRepository

All Implemented Interfaces:

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

@Repository
public class JdbcMessageRepository
extends Object
implements ch.admin.bit.jeap.messageexchange.domain.database.MessageRepository

Constructor Summary

Constructors

Constructor	Description
JdbcMessageRepository(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.Message>	findByBpIdAndMessageId(String bpId, UUID messageId)
Optional<ch.admin.bit.jeap.messageexchange.domain.Message>	findByMessageId(UUID messageId)
List<ch.admin.bit.jeap.messageexchange.domain.dto.MessageSearchResultDto>	getMessages(String bpId, String topicName, String groupId, UUID lastMessageId, String partnerTopic, String partnerExternalReference, int size)
Optional<ch.admin.bit.jeap.messageexchange.domain.Message>	getNextMessage(UUID lastMessageId, String bpId, String partnerTopic, String topicName, String partnerExternalReference)
void	save(ch.admin.bit.jeap.messageexchange.domain.Message message)

Methods inherited from class java.lang.Object

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

Constructor Details

JdbcMessageRepository

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

Method Details

save

@Transactional
public void save(ch.admin.bit.jeap.messageexchange.domain.Message message)

Specified by:

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

findByMessageId

public Optional<ch.admin.bit.jeap.messageexchange.domain.Message> findByMessageId(UUID messageId)

Specified by:

findByMessageId in interface ch.admin.bit.jeap.messageexchange.domain.database.MessageRepository

findByBpIdAndMessageId

public Optional<ch.admin.bit.jeap.messageexchange.domain.Message> findByBpIdAndMessageId(String bpId,
 UUID messageId)

Specified by:

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

getMessages

public List<ch.admin.bit.jeap.messageexchange.domain.dto.MessageSearchResultDto> getMessages(String bpId,
 String topicName,
 String groupId,
 UUID lastMessageId,
 String partnerTopic,
 String partnerExternalReference,
 int size)

Specified by:

getMessages in interface ch.admin.bit.jeap.messageexchange.domain.database.MessageRepository

deleteExpiredMessages

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

Specified by:

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

getNextMessage

public Optional<ch.admin.bit.jeap.messageexchange.domain.Message> getNextMessage(UUID lastMessageId,
 String bpId,
 String partnerTopic,
 String topicName,
 String partnerExternalReference)

Specified by:

getNextMessage in interface ch.admin.bit.jeap.messageexchange.domain.database.MessageRepository