com.github.mongobee.dao

Class ChangeEntryDao

java.lang.Object

com.github.mongobee.dao.ChangeEntryDao

public class ChangeEntryDao
extends Object

Since:

27/07/2014

Author:

lstolowski

Constructor Summary

Constructors

Constructor and Description
ChangeEntryDao(String changelogCollectionName, String lockCollectionName)

Method Summary

Modifier and Type	Method and Description
boolean	acquireProcessLock() Try to acquire process lock
void	close()
com.mongodb.client.MongoDatabase	connectMongoDb(com.mongodb.MongoClient mongo, String dbName)
com.mongodb.client.MongoDatabase	connectMongoDb(com.mongodb.MongoClientURI mongoClientURI, String dbName)
com.mongodb.DB	getDb() Deprecated. implemented only for Jongo driver compatibility and backward compatibility - do not use in other contexts
com.mongodb.client.MongoDatabase	getMongoDatabase()
boolean	isNewChange(ChangeEntry changeEntry)
boolean	isProccessLockHeld()
void	releaseProcessLock()
void	save(ChangeEntry changeEntry)
void	setChangelogCollectionName(String changelogCollectionName)
void	setIndexDao(ChangeEntryIndexDao changeEntryIndexDao)
void	setLockCollectionName(String lockCollectionName)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChangeEntryDao

public ChangeEntryDao(String changelogCollectionName,
                      String lockCollectionName)

Method Detail

getMongoDatabase

public com.mongodb.client.MongoDatabase getMongoDatabase()

getDb

public com.mongodb.DB getDb()

Deprecated. implemented only for Jongo driver compatibility and backward compatibility - do not use in other contexts

Returns:

com.mongodb.DB

connectMongoDb

public com.mongodb.client.MongoDatabase connectMongoDb(com.mongodb.MongoClient mongo,
                                                       String dbName)
                                                throws MongobeeConfigurationException

Throws:

MongobeeConfigurationException

connectMongoDb

public com.mongodb.client.MongoDatabase connectMongoDb(com.mongodb.MongoClientURI mongoClientURI,
                                                       String dbName)
                                                throws MongobeeConfigurationException,
                                                       MongobeeConnectionException

Throws:

MongobeeConfigurationException

MongobeeConnectionException

acquireProcessLock

public boolean acquireProcessLock()
                           throws MongobeeConnectionException

Try to acquire process lock

Returns:

true if successfully acquired, false otherwise

Throws:

MongobeeConnectionException - exception

releaseProcessLock

public void releaseProcessLock()
                        throws MongobeeConnectionException

Throws:

MongobeeConnectionException

isProccessLockHeld

public boolean isProccessLockHeld()
                           throws MongobeeConnectionException

Throws:

MongobeeConnectionException

isNewChange

public boolean isNewChange(ChangeEntry changeEntry)
                    throws MongobeeConnectionException

Throws:

MongobeeConnectionException

save

public void save(ChangeEntry changeEntry)
          throws MongobeeConnectionException

Throws:

MongobeeConnectionException

close

public void close()

setIndexDao

public void setIndexDao(ChangeEntryIndexDao changeEntryIndexDao)

setChangelogCollectionName

public void setChangelogCollectionName(String changelogCollectionName)

setLockCollectionName

public void setLockCollectionName(String lockCollectionName)