public class ClusterMessageDAOHibernate extends StatelessDao implements ClusterMessageDao
sessionFactory
Constructor and Description |
---|
ClusterMessageDAOHibernate() |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(InternalClusterMessage message) |
int |
deleteClusterMessagesBeforeAndOn(long toTimestamp)
Deletes all mesages older than the timestamp.
|
Long |
getHighestId()
Finds the highest ID currently in database.
|
List<InternalClusterMessage> |
getMessagesAfter(String excludeNodeId,
long fromId)
Fetches messages with ID higher than the specified threshold.
|
setSessionFactory, withStatelessSession
public void addMessage(InternalClusterMessage message)
addMessage
in interface ClusterMessageDao
public List<InternalClusterMessage> getMessagesAfter(String excludeNodeId, long fromId)
ClusterMessageDao
getMessagesAfter
in interface ClusterMessageDao
excludeNodeId
- node that should be excluded from search (this will usually be the calling node); null to include all nodesfromId
- start message ID for the search, non-inclusivepublic int deleteClusterMessagesBeforeAndOn(long toTimestamp)
ClusterMessageDao
deleteClusterMessagesBeforeAndOn
in interface ClusterMessageDao
public Long getHighestId()
ClusterMessageDao
getHighestId
in interface ClusterMessageDao
Copyright © 2021 Atlassian. All rights reserved.