Package tigase.archive.unified.db
Class UnifiedArchiveRepositoryPool
- java.lang.Object
-
- tigase.db.beans.MDRepositoryBean<T>
-
- tigase.db.beans.MDRepositoryBeanWithStatistics<R>
-
- tigase.archive.db.MessageArchiveRepositoryPool<QueryCriteria,UnifiedArchiveRepository<tigase.db.DataSource>>
-
- tigase.archive.unified.db.UnifiedArchiveRepositoryPool
-
- All Implemented Interfaces:
tigase.archive.db.MessageArchiveRepository<QueryCriteria,tigase.db.DataSource>
,UnifiedArchiveRepository<tigase.db.DataSource>
,tigase.db.DataSourceAware<tigase.db.DataSource>
,tigase.kernel.beans.Initializable
,tigase.kernel.beans.RegistrarBean
,tigase.kernel.beans.RegistrarBeanWithDefaultBeanClass
,tigase.kernel.beans.UnregisterAware
,tigase.stats.ComponentStatisticsProvider
,tigase.stats.StatisticsProviderIfc
,tigase.xmpp.mam.MAMRepository<QueryCriteria,tigase.xmpp.mam.MAMRepository.Item>
@Bean(name="repositoryPool", parent=UnifiedArchiveComponent.class, active=true) public class UnifiedArchiveRepositoryPool extends tigase.archive.db.MessageArchiveRepositoryPool<QueryCriteria,UnifiedArchiveRepository<tigase.db.DataSource>> implements UnifiedArchiveRepository<tigase.db.DataSource>
Created by andrzej on 17.07.2016.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class tigase.archive.db.MessageArchiveRepositoryPool
tigase.archive.db.MessageArchiveRepositoryPool.MessageArchiveRepositoryConfigBean
-
Nested classes/interfaces inherited from class tigase.db.beans.MDRepositoryBean
tigase.db.beans.MDRepositoryBean.MDRepositoryConfigBean<A extends tigase.db.DataSourceAware>, tigase.db.beans.MDRepositoryBean.SelectorType
-
Nested classes/interfaces inherited from interface tigase.xmpp.mam.MAMRepository
tigase.xmpp.mam.MAMRepository.ItemHandler<Q extends tigase.xmpp.mam.Query,I extends tigase.xmpp.mam.MAMRepository.Item>
-
Nested classes/interfaces inherited from interface tigase.archive.db.MessageArchiveRepository
tigase.archive.db.MessageArchiveRepository.CollectionHandler<Q extends tigase.xmpp.mam.Query>, tigase.archive.db.MessageArchiveRepository.Direction, tigase.archive.db.MessageArchiveRepository.Item
-
Nested classes/interfaces inherited from interface tigase.archive.unified.db.UnifiedArchiveRepository
UnifiedArchiveRepository.CallCondition, UnifiedArchiveRepository.Item, UnifiedArchiveRepository.Type
-
-
Constructor Summary
Constructors Constructor Description UnifiedArchiveRepositoryPool()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.Class
findClassForDataSource(tigase.db.DataSource dataSource)
java.util.stream.Stream<? extends UnifiedArchiveRepository.Item>
queryRecents(tigase.xmpp.jid.BareJID ownerJid, java.util.Date start, java.util.Date end, java.util.Set<UnifiedArchiveRepository.Type> types, java.util.Set<UnifiedArchiveRepository.CallCondition> callConditions, tigase.xmpp.rsm.RSM rsm)
-
Methods inherited from class tigase.archive.db.MessageArchiveRepositoryPool
archiveMessage, belongsTo, deleteExpiredMessages, getDefaultBeanClass, getTags, newQuery, queryCollections, queryItems, removeItems, setDataSource
-
Methods inherited from class tigase.db.beans.MDRepositoryBeanWithStatistics
everyHour, everyMinute, everySecond, getRepositories, getRepository, getStatistics, setStatisticsEnabled, updateDataSourceAware, wrapInProxy
-
Methods inherited from class tigase.db.beans.MDRepositoryBean
beforeUnregister, getName, initialize, initializeRepository, onDataSourceChange, register, registerIfNotExists, repositoriesStream, setDataSourceBean, unregister
-
-
-
-
Method Detail
-
queryRecents
public java.util.stream.Stream<? extends UnifiedArchiveRepository.Item> queryRecents(tigase.xmpp.jid.BareJID ownerJid, java.util.Date start, java.util.Date end, java.util.Set<UnifiedArchiveRepository.Type> types, java.util.Set<UnifiedArchiveRepository.CallCondition> callConditions, tigase.xmpp.rsm.RSM rsm) throws tigase.db.TigaseDBException
- Specified by:
queryRecents
in interfaceUnifiedArchiveRepository<tigase.db.DataSource>
- Throws:
tigase.db.TigaseDBException
-
findClassForDataSource
protected java.lang.Class findClassForDataSource(tigase.db.DataSource dataSource) throws tigase.db.DBInitException
- Overrides:
findClassForDataSource
in classtigase.archive.db.MessageArchiveRepositoryPool<QueryCriteria,UnifiedArchiveRepository<tigase.db.DataSource>>
- Throws:
tigase.db.DBInitException
-
-