Package tigase.server.amp.db
Class MsgRepository<T,S extends DataSource>
java.lang.Object
tigase.server.amp.db.MsgRepository<T,S>
- All Implemented Interfaces:
DataSourceAware<S>
,MsgRepositoryIfc<S>
,OfflineMsgRepositoryIfc
,Repository
- Direct Known Subclasses:
JDBCMsgRepository
,XMLMsgRepository
public abstract class MsgRepository<T,S extends DataSource>
extends Object
implements MsgRepositoryIfc<S>
- Author:
- andrzej
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic enum
static class
static class
Bean used to provide MsgRepository implementationsstatic interface
Deprecated.static interface
Nested classes/interfaces inherited from interface tigase.db.Repository
Repository.Meta, Repository.SchemaId
-
Field Summary
Modifier and TypeFieldDescriptionprotected AtomicInteger
protected long
protected DelayQueue<MsgRepository.MsgDBItem<T>>
protected static final int
static final String
static final String
protected SimpleParser
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
deleteMessage
(T db_id) abstract int
deleteMessagesToJID
(List<String> db_ids, XMPPResourceConnection session) static MsgRepositoryIfc
getInstance
(String cls, String id_string) getMessageExpired
(long time, boolean delete) Deprecated.protected long
getMsgsStoreLimit
(BareJID userJid, NonAuthUserRepository userRepo) void
initRepository
(String conn_str, Map<String, String> map) Deprecated.protected abstract void
loadExpiredQueue
(int max) Deprecated.protected abstract void
loadExpiredQueue
(Date expired) Deprecated.loadMessagesToJID
(List<String> db_ids, XMPPResourceConnection session, boolean delete, MsgRepository.OfflineMessagesProcessor proc) void
setCondition
(ReentrantLock lock, Condition condition) Deprecated.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface tigase.db.DataSourceAware
setDataSource
Methods inherited from interface tigase.db.MsgRepositoryIfc
getMessagesCount, getMessagesList
Methods inherited from interface tigase.db.OfflineMsgRepositoryIfc
loadMessagesToJID, storeMessage
-
Field Details
-
OFFLINE_MSGS_KEY
- See Also:
-
MSGS_STORE_LIMIT_KEY
- See Also:
-
MAX_QUEUE_SIZE
protected static final int MAX_QUEUE_SIZE- See Also:
-
awaitingInExpiredQueue
-
earliestOffline
protected long earliestOffline -
parser
-
expiredQueue
-
-
Constructor Details
-
MsgRepository
public MsgRepository()
-
-
Method Details
-
getInstance
- Throws:
TigaseDBException
-
loadMessagesToJID
public abstract Queue<Element> loadMessagesToJID(List<String> db_ids, XMPPResourceConnection session, boolean delete, MsgRepository.OfflineMessagesProcessor proc) throws UserNotFoundException - Specified by:
loadMessagesToJID
in interfaceMsgRepositoryIfc<T>
- Throws:
UserNotFoundException
-
deleteMessagesToJID
public abstract int deleteMessagesToJID(List<String> db_ids, XMPPResourceConnection session) throws UserNotFoundException - Specified by:
deleteMessagesToJID
in interfaceMsgRepositoryIfc<T>
- Throws:
UserNotFoundException
-
initRepository
@Deprecated public void initRepository(String conn_str, Map<String, String> map) throws DBInitExceptionDeprecated.Description copied from interface:Repository
Method is deprecated and should not be user any more.
The method is called to initialize the data repository. Depending on the implementation all the initialization parameters can be passed either viaresource_uri
parameter as the database connection string or viaparams
map if the required repository parameters are more complex or both.- Specified by:
initRepository
in interfaceRepository
- Parameters:
conn_str
- value in most cases representing the database connection string.map
- is aMap
with repository properties necessary to initialize and perform all the functions. The initialization parameters are implementation dependent.- Throws:
DBInitException
- if there was an error during repository initialization. Some implementations, though, perform so called lazy initialization so even though there is a problem with the underlying repository it may not be signaled through this method call.
-
getMessageExpired
Deprecated.Description copied from interface:OfflineMsgRepositoryIfc
Loads head of the payloads queue which holds items that would be expired after stated time with an option to delete them from repository after being retrieved. This is blocking method, which means if there is not data to return, implementation should block the call until data is available.- Specified by:
getMessageExpired
in interfaceOfflineMsgRepositoryIfc
- Parameters:
time
- time in milliseconds representing time after which given message would be considered as expireddelete
- boolean parameter controlling whether messages should be removed from repository after they retrieved.- Returns:
- head of the payloads queue which holds items that would be expired after stated time with an option to delete them from repository after being retrieved.
-
setCondition
Deprecated.- Specified by:
setCondition
in interfaceMsgRepositoryIfc<T>
-
loadExpiredQueue
Deprecated. -
loadExpiredQueue
Deprecated. -
deleteMessage
-
getMsgsStoreLimit
protected long getMsgsStoreLimit(BareJID userJid, NonAuthUserRepository userRepo) throws UserNotFoundException - Throws:
UserNotFoundException
-