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

Class JdbcMessageRepository

java.lang.Object

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

All Implemented Interfaces:

MessageRepository

@Repository
public class JdbcMessageRepository
extends Object
implements 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<Message>	findByMessageId(UUID messageId)
List<MessageSearchResultDto>	getMessages(String bpId, String topicName, String groupId, UUID lastMessageId, String partnerTopic, int size)
Optional<UUID>	getNextMessageId(UUID lastMessageId, String bpId, String partnerTopic, String topicName)
void	save(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(Message message)

Specified by:

save in interface MessageRepository

findByMessageId

public Optional<Message> findByMessageId(UUID messageId)

Specified by:

findByMessageId in interface MessageRepository

getMessages

public List<MessageSearchResultDto> getMessages(String bpId,
 String topicName,
 String groupId,
 UUID lastMessageId,
 String partnerTopic,
 int size)

Specified by:

getMessages in interface MessageRepository

getNextMessageId

public Optional<UUID> getNextMessageId(UUID lastMessageId,
 String bpId,
 String partnerTopic,
 String topicName)

Specified by:

getNextMessageId in interface MessageRepository

deleteExpiredMessages

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

Specified by:

deleteExpiredMessages in interface MessageRepository