MongoMsgRepository¶

public class MongoMsgRepository extends MsgRepository<ObjectId, MongoDataSource> implements MongoRepositoryVersionAware ¶

Author:	andrzej

Methods¶

deleteMessage¶

protected void deleteMessage(ObjectId dbId)¶

deleteMessagesToJID¶

public int deleteMessagesToJID(List<String> db_ids, XMPPResourceConnection session)¶

getMessageExpired¶

public Element getMessageExpired(long time, boolean delete)¶

getMessagesCount¶

public Map<Enum, Long> getMessagesCount(JID to)¶

getMessagesList¶

public List<Element> getMessagesList(JID to)¶

initRepository¶

public void initRepository(String resource_uri, Map<String, String> params)¶

loadExpiredQueue¶

protected void loadExpiredQueue(int max)¶

loadExpiredQueue¶

protected void loadExpiredQueue(Date expired)¶

loadMessagesToJID¶

public Queue<Element> loadMessagesToJID(XMPPResourceConnection session, boolean delete)¶

loadMessagesToJID¶

public Queue<Element> loadMessagesToJID(XMPPResourceConnection session, boolean delete, OfflineMessagesProcessor proc)¶

loadMessagesToJID¶

public Queue<Element> loadMessagesToJID(List<String> db_ids, XMPPResourceConnection session, boolean delete, OfflineMessagesProcessor proc)¶

setDataSource¶

public void setDataSource(MongoDataSource dataSource)¶

storeMessage¶

public boolean storeMessage(JID from, JID to, Date expired, Element msg, NonAuthUserRepository userRepo)¶

updateSchema¶

public SchemaLoader.Result updateSchema(Optional<Version> oldVersion, Version newVersion)¶