Package tigase.mongodb
Class MongoMsgRepository
- java.lang.Object
-
- tigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
-
- tigase.mongodb.MongoMsgRepository
-
- All Implemented Interfaces:
tigase.db.DataSourceAware<MongoDataSource>
,tigase.db.MsgRepositoryIfc<MongoDataSource>
,tigase.db.OfflineMsgRepositoryIfc
,tigase.db.Repository
,tigase.db.util.RepositoryVersionAware
,MongoRepositoryVersionAware
public class MongoMsgRepository extends tigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource> implements MongoRepositoryVersionAware
- Author:
- andrzej
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class tigase.server.amp.db.MsgRepository
tigase.server.amp.db.MsgRepository.MSG_TYPES, tigase.server.amp.db.MsgRepository.MsgDBItem<T extends java.lang.Object>, tigase.server.amp.db.MsgRepository.MsgRepositoryMDBean, tigase.server.amp.db.MsgRepository.OfflineMessagesProcessor
-
-
Constructor Summary
Constructors Constructor Description MongoMsgRepository()
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected void
deleteMessage(org.bson.types.ObjectId dbId)
int
deleteMessagesToJID(java.util.List<java.lang.String> db_ids, tigase.xmpp.XMPPResourceConnection session)
tigase.xml.Element
getMessageExpired(long time, boolean delete)
java.util.Map<java.lang.Enum,java.lang.Long>
getMessagesCount(tigase.xmpp.jid.JID to)
java.util.List<tigase.xml.Element>
getMessagesList(tigase.xmpp.jid.JID to)
void
initRepository(java.lang.String resource_uri, java.util.Map<java.lang.String,java.lang.String> params)
Deprecated.protected void
loadExpiredQueue(int max)
protected void
loadExpiredQueue(java.util.Date expired)
java.util.Queue<tigase.xml.Element>
loadMessagesToJID(java.util.List<java.lang.String> db_ids, tigase.xmpp.XMPPResourceConnection session, boolean delete, tigase.server.amp.db.MsgRepository.OfflineMessagesProcessor proc)
java.util.Queue<tigase.xml.Element>
loadMessagesToJID(tigase.xmpp.XMPPResourceConnection session, boolean delete)
java.util.Queue<tigase.xml.Element>
loadMessagesToJID(tigase.xmpp.XMPPResourceConnection session, boolean delete, tigase.server.amp.db.MsgRepository.OfflineMessagesProcessor proc)
void
setDataSource(MongoDataSource dataSource)
boolean
storeMessage(tigase.xmpp.jid.JID from, tigase.xmpp.jid.JID to, java.util.Date expired, tigase.xml.Element msg, tigase.db.NonAuthUserRepository userRepo)
tigase.db.util.SchemaLoader.Result
updateSchema(java.util.Optional<tigase.util.Version> oldVersion, tigase.util.Version newVersion)
-
Methods inherited from class tigase.server.amp.db.MsgRepository
getInstance, getMsgsStoreLimit, setCondition
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface tigase.mongodb.MongoRepositoryVersionAware
getVersion
-
-
-
-
Method Detail
-
deleteMessage
protected void deleteMessage(org.bson.types.ObjectId dbId)
- Specified by:
deleteMessage
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
-
deleteMessagesToJID
public int deleteMessagesToJID(java.util.List<java.lang.String> db_ids, tigase.xmpp.XMPPResourceConnection session) throws tigase.db.UserNotFoundException
- Specified by:
deleteMessagesToJID
in interfacetigase.db.MsgRepositoryIfc<MongoDataSource>
- Specified by:
deleteMessagesToJID
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
- Throws:
tigase.db.UserNotFoundException
-
getMessageExpired
public tigase.xml.Element getMessageExpired(long time, boolean delete)
- Specified by:
getMessageExpired
in interfacetigase.db.OfflineMsgRepositoryIfc
- Overrides:
getMessageExpired
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
-
getMessagesCount
public java.util.Map<java.lang.Enum,java.lang.Long> getMessagesCount(tigase.xmpp.jid.JID to) throws tigase.db.UserNotFoundException
- Specified by:
getMessagesCount
in interfacetigase.db.MsgRepositoryIfc<MongoDataSource>
- Throws:
tigase.db.UserNotFoundException
-
getMessagesList
public java.util.List<tigase.xml.Element> getMessagesList(tigase.xmpp.jid.JID to) throws tigase.db.UserNotFoundException
- Specified by:
getMessagesList
in interfacetigase.db.MsgRepositoryIfc<MongoDataSource>
- Throws:
tigase.db.UserNotFoundException
-
initRepository
@Deprecated public void initRepository(java.lang.String resource_uri, java.util.Map<java.lang.String,java.lang.String> params) throws tigase.db.DBInitException
Deprecated.- Specified by:
initRepository
in interfacetigase.db.Repository
- Overrides:
initRepository
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
- Throws:
tigase.db.DBInitException
-
loadExpiredQueue
protected void loadExpiredQueue(int max)
- Specified by:
loadExpiredQueue
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
-
loadExpiredQueue
protected void loadExpiredQueue(java.util.Date expired)
- Specified by:
loadExpiredQueue
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
-
loadMessagesToJID
public java.util.Queue<tigase.xml.Element> loadMessagesToJID(tigase.xmpp.XMPPResourceConnection session, boolean delete) throws tigase.db.UserNotFoundException
- Specified by:
loadMessagesToJID
in interfacetigase.db.OfflineMsgRepositoryIfc
- Throws:
tigase.db.UserNotFoundException
-
loadMessagesToJID
public java.util.Queue<tigase.xml.Element> loadMessagesToJID(tigase.xmpp.XMPPResourceConnection session, boolean delete, tigase.server.amp.db.MsgRepository.OfflineMessagesProcessor proc) throws tigase.db.UserNotFoundException
- Throws:
tigase.db.UserNotFoundException
-
loadMessagesToJID
public java.util.Queue<tigase.xml.Element> loadMessagesToJID(java.util.List<java.lang.String> db_ids, tigase.xmpp.XMPPResourceConnection session, boolean delete, tigase.server.amp.db.MsgRepository.OfflineMessagesProcessor proc) throws tigase.db.UserNotFoundException
- Specified by:
loadMessagesToJID
in interfacetigase.db.MsgRepositoryIfc<MongoDataSource>
- Specified by:
loadMessagesToJID
in classtigase.server.amp.db.MsgRepository<org.bson.types.ObjectId,MongoDataSource>
- Throws:
tigase.db.UserNotFoundException
-
setDataSource
public void setDataSource(MongoDataSource dataSource)
- Specified by:
setDataSource
in interfacetigase.db.DataSourceAware<MongoDataSource>
-
storeMessage
public boolean storeMessage(tigase.xmpp.jid.JID from, tigase.xmpp.jid.JID to, java.util.Date expired, tigase.xml.Element msg, tigase.db.NonAuthUserRepository userRepo) throws tigase.db.UserNotFoundException
- Specified by:
storeMessage
in interfacetigase.db.OfflineMsgRepositoryIfc
- Throws:
tigase.db.UserNotFoundException
-
updateSchema
public tigase.db.util.SchemaLoader.Result updateSchema(java.util.Optional<tigase.util.Version> oldVersion, tigase.util.Version newVersion) throws tigase.db.TigaseDBException
- Specified by:
updateSchema
in interfacetigase.db.util.RepositoryVersionAware
- Throws:
tigase.db.TigaseDBException
-
-