Package tigase.server.amp.db
Class JDBCMsgRepository
- All Implemented Interfaces:
DataSourceAware<DataRepository>,MsgRepositoryIfc<DataRepository>,OfflineMsgRepositoryIfc,Repository,RepositoryVersionAware
public class JDBCMsgRepository
extends MsgRepository<Long,DataRepository>
implements RepositoryVersionAware
Created: May 3, 2010 5:28:02 PM
- Author:
- Artur Hefczyc
-
Nested Class Summary
Nested classes/interfaces inherited from class tigase.server.amp.db.MsgRepository
MsgRepository.MSG_TYPES, MsgRepository.MsgDBItem<T>, MsgRepository.MsgRepositoryMDBean, MsgRepository.MsgRepositoryPoolBean<T>, MsgRepository.OfflineMessagesProcessorNested classes/interfaces inherited from interface tigase.db.Repository
Repository.Meta, Repository.SchemaIdNested classes/interfaces inherited from interface tigase.db.util.RepositoryVersionAware
RepositoryVersionAware.SchemaVersion -
Field Summary
FieldsFields inherited from class tigase.server.amp.db.MsgRepository
awaitingInExpiredQueue, earliestOffline, expiredQueue, MAX_QUEUE_SIZE, MSGS_STORE_LIMIT_KEY, OFFLINE_MSGS_KEY, parser -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddeleteMessage(Long msg_id) intdeleteMessagesToJID(List<String> db_ids, XMPPResourceConnection session) getMessagesCount(JID to) getMessagesList(JID to) voidinitRepository(String conn_str, Map<String, String> map) Deprecated.protected voidloadExpiredQueue(int min_elements) protected voidloadExpiredQueue(Date expired) loadMessagesToJID(List<String> db_ids, XMPPResourceConnection session, boolean delete, MsgRepository.OfflineMessagesProcessor proc) loadMessagesToJID(XMPPResourceConnection session, boolean delete) Loads all payloads for the given user'sJIDfrom repository.loadMessagesToJID(XMPPResourceConnection session, boolean delete, MsgRepository.OfflineMessagesProcessor proc) protected MsgRepository.MsgDBItemparseExpiredMessage(DomBuilderHandler domHandler, ResultSet rs) voidsetDataSource(DataRepository data_repo) Method called to provide class with instance of a data source.booleanstoreMessage(JID from, JID to, Date expired, Element msg, NonAuthUserRepository userRepo) Saves the massage to the repositoryMethods inherited from class tigase.server.amp.db.MsgRepository
getInstance, getMessageExpired, getMsgsStoreLimit, setConditionMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface tigase.db.util.RepositoryVersionAware
getVersion, updateSchema
-
Field Details
-
data_repo
-
-
Constructor Details
-
JDBCMsgRepository
public JDBCMsgRepository()
-
-
Method Details
-
setDataSource
Description copied from interface:DataSourceAwareMethod called to provide class with instance of a data source.- Specified by:
setDataSourcein interfaceDataSourceAware<DataRepository>
-
initRepository
@Deprecated public void initRepository(String conn_str, Map<String, String> map) throws DBInitExceptionDeprecated.Description copied from interface:RepositoryMethod 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_uriparameter as the database connection string or viaparamsmap if the required repository parameters are more complex or both.- Specified by:
initRepositoryin interfaceRepository- Overrides:
initRepositoryin classMsgRepository<Long,DataRepository> - Parameters:
conn_str- value in most cases representing the database connection string.map- is aMapwith 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.
-
getMessagesCount
- Specified by:
getMessagesCountin interfaceMsgRepositoryIfc<DataRepository>
-
getMessagesList
- Specified by:
getMessagesListin interfaceMsgRepositoryIfc<DataRepository>
-
loadMessagesToJID
public Queue<Element> loadMessagesToJID(List<String> db_ids, XMPPResourceConnection session, boolean delete, MsgRepository.OfflineMessagesProcessor proc) throws UserNotFoundException - Specified by:
loadMessagesToJIDin interfaceMsgRepositoryIfc<DataRepository>- Specified by:
loadMessagesToJIDin classMsgRepository<Long,DataRepository> - Throws:
UserNotFoundException
-
deleteMessagesToJID
public int deleteMessagesToJID(List<String> db_ids, XMPPResourceConnection session) throws UserNotFoundException - Specified by:
deleteMessagesToJIDin interfaceMsgRepositoryIfc<DataRepository>- Specified by:
deleteMessagesToJIDin classMsgRepository<Long,DataRepository> - Throws:
UserNotFoundException
-
loadMessagesToJID
public Queue<Element> loadMessagesToJID(XMPPResourceConnection session, boolean delete) throws UserNotFoundException Description copied from interface:OfflineMsgRepositoryIfcLoads all payloads for the given user'sJIDfrom repository.- Specified by:
loadMessagesToJIDin interfaceOfflineMsgRepositoryIfc- Parameters:
session- user session which keeps all the user session data and also gives an access to the user's repository data.delete- boolean parameter controlling whether messages should be removed from repository after they retrieved.- Returns:
- a
QueueofElementobjects representing stored payloads for the given user'sJID - Throws:
UserNotFoundException
-
loadMessagesToJID
public Queue<Element> loadMessagesToJID(XMPPResourceConnection session, boolean delete, MsgRepository.OfflineMessagesProcessor proc) throws UserNotFoundException - Throws:
UserNotFoundException
-
storeMessage
public boolean storeMessage(JID from, JID to, Date expired, Element msg, NonAuthUserRepository userRepo) throws UserNotFoundException Description copied from interface:OfflineMsgRepositoryIfcSaves the massage to the repository- Specified by:
storeMessagein interfaceOfflineMsgRepositoryIfc- Parameters:
from-JIDdenotes address of the senderto-JIDdenotes address of the receiverexpired-Dateobject denoting expiration date of the messagemsg-Elementpayload of the stanza to be saveduserRepo-NonAuthUserRepositoryinstance of non auth user repository to get user settings for offline messages- Returns:
trueif the packet was correctly saved to repository,falseotherwise.- Throws:
UserNotFoundException
-
parseLoadedMessages
protected Queue<Element> parseLoadedMessages(MsgRepository.OfflineMessagesProcessor proc, ResultSet rs) throws SQLException - Throws:
SQLException
-
deleteMessage
- Specified by:
deleteMessagein classMsgRepository<Long,DataRepository>
-
loadExpiredQueue
protected void loadExpiredQueue(int min_elements) - Specified by:
loadExpiredQueuein classMsgRepository<Long,DataRepository>
-
loadExpiredQueue
- Specified by:
loadExpiredQueuein classMsgRepository<Long,DataRepository>
-
parseExpiredMessage
protected MsgRepository.MsgDBItem parseExpiredMessage(DomBuilderHandler domHandler, ResultSet rs) throws SQLException - Throws:
SQLException
-