Package com.atlassian.crowd.dao.cluster

Class ClusterMessageDAOHibernate

java.lang.Object

com.atlassian.crowd.util.persistence.hibernate.StatelessDao

com.atlassian.crowd.dao.cluster.ClusterMessageDAOHibernate

All Implemented Interfaces:

ClusterMessageDao

public class ClusterMessageDAOHibernate
extends StatelessDao
implements ClusterMessageDao

Field Summary

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

sessionFactory

Constructor Summary

Constructors

Constructor	Description
ClusterMessageDAOHibernate()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

setSessionFactory, withStatelessSession

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterMessageDAOHibernate

public ClusterMessageDAOHibernate()

Method Details

addMessage

public void addMessage(InternalClusterMessage message)

Specified by:

addMessage in interface ClusterMessageDao

getMessagesAfter

public List<InternalClusterMessage> getMessagesAfter(String excludeNodeId,
 long fromId)

Description copied from interface: ClusterMessageDao

Fetches messages with ID higher than the specified threshold.

Specified by:

getMessagesAfter in interface ClusterMessageDao

Parameters:

excludeNodeId - node that should be excluded from search (this will usually be the calling node); null to include all nodes

fromId - start message ID for the search, non-inclusive

Returns:

list of results in ascending ID order

deleteClusterMessagesBeforeAndOn

public int deleteClusterMessagesBeforeAndOn(long toTimestamp)

Description copied from interface: ClusterMessageDao

Deletes all mesages older than the timestamp.

Specified by:

deleteClusterMessagesBeforeAndOn in interface ClusterMessageDao

Returns:

number of messages deleted

getHighestId

public Long getHighestId()

Description copied from interface: ClusterMessageDao

Finds the highest ID currently in database.

Specified by:

getHighestId in interface ClusterMessageDao

Returns:

highest ID found, or null if there are no rows