Package tigase.pubsub.repository
Class PubSubDAOPool<T,S extends tigase.db.DataSource,Q extends Query>
- java.lang.Object
-
- tigase.db.beans.MDRepositoryBean<T>
-
- tigase.db.beans.MDRepositoryBeanWithStatistics<IPubSubDAO<T,S,Q>>
-
- tigase.pubsub.repository.PubSubDAOPool<T,S,Q>
-
- All Implemented Interfaces:
tigase.db.DataSourceAware<S>
,tigase.kernel.beans.Initializable
,tigase.kernel.beans.RegistrarBean
,tigase.kernel.beans.RegistrarBeanWithDefaultBeanClass
,tigase.kernel.beans.UnregisterAware
,IPubSubDAO<T,S,Q>
,tigase.stats.ComponentStatisticsProvider
,tigase.stats.StatisticsProviderIfc
@Bean(name="dao", parent=PubSubComponent.class, active=true) public class PubSubDAOPool<T,S extends tigase.db.DataSource,Q extends Query> extends tigase.db.beans.MDRepositoryBeanWithStatistics<IPubSubDAO<T,S,Q>> implements IPubSubDAO<T,S,Q>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
PubSubDAOPool.PubSubDAOConfigBean
-
Constructor Summary
Constructors Constructor Description PubSubDAOPool()
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
addMAMItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String uuid, tigase.xml.Element message, java.lang.String itemId)
boolean
belongsTo(java.lang.Class<? extends tigase.server.BasicComponent> component)
T
createNode(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName, tigase.xmpp.jid.BareJID ownerJid, AbstractNodeConfig nodeConfig, NodeType nodeType, T collectionId, boolean autocreateService)
void
createService(tigase.xmpp.jid.BareJID serviceJID, boolean isPublic)
void
deleteItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String id)
void
deleteNode(tigase.xmpp.jid.BareJID serviceJid, T nodeId)
void
deleteService(tigase.xmpp.jid.BareJID serviceJid)
void
destroy()
protected java.lang.Class<? extends IPubSubDAO<T,S,Q>>
findClassForDataSource(tigase.db.DataSource dataSource)
java.lang.String[]
getAllNodesList(tigase.xmpp.jid.BareJID serviceJid)
java.lang.String[]
getChildNodes(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName)
java.lang.Class<?>
getDefaultBeanClass()
IItems.IItem
getItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String id)
java.util.List<IItems.IItem>
getItems(tigase.xmpp.jid.BareJID serviceJid, java.util.List<T> nodesIds, java.util.Date after, java.util.Date before, tigase.xmpp.rsm.RSM rsm, CollectionItemsOrdering ordering)
java.lang.String[]
getItemsIds(tigase.xmpp.jid.BareJID serviceJid, T nodeId, CollectionItemsOrdering order)
java.lang.String[]
getItemsIdsSince(tigase.xmpp.jid.BareJID serviceJid, T nodeId, CollectionItemsOrdering order, java.util.Date since)
java.util.List<IItems.ItemMeta>
getItemsMeta(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String nodeName)
java.util.Map<tigase.xmpp.jid.BareJID,UsersAffiliation>
getNodeAffiliations(tigase.xmpp.jid.BareJID serviceJid, T nodeId)
INodeMeta<T>
getNodeMeta(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName)
long
getNodesCount(tigase.xmpp.jid.BareJID serviceJid)
java.lang.String[]
getNodesList(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName)
java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription>
getNodeSubscriptions(tigase.xmpp.jid.BareJID serviceJid, T nodeId)
protected java.lang.String
getPoolDetails(tigase.xmpp.jid.BareJID serviceJid)
Deprecated.java.util.List<tigase.xmpp.jid.BareJID>
getServices(tigase.xmpp.jid.BareJID domain, java.lang.Boolean isPublic)
java.util.Map<java.lang.String,UsersAffiliation>
getUserAffiliations(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid)
java.util.Map<tigase.xmpp.jid.BareJID,tigase.xmpp.impl.roster.RosterElement>
getUserRoster(tigase.xmpp.jid.BareJID owner)
java.util.Map<java.lang.String,UsersSubscription>
getUserSubscriptions(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid)
protected void
offerDao(tigase.xmpp.jid.BareJID serviceJid, IPubSubDAO dao)
Deprecated.AbstractNodeConfig
parseConfig(java.lang.String nodeName, java.lang.String cfgData)
void
queryItems(Q query, T nodeId, tigase.xmpp.mam.MAMRepository.ItemHandler<Q,tigase.xmpp.mam.MAMRepository.Item> itemHandler)
void
removeNodeSubscription(tigase.xmpp.jid.BareJID serviceJid, T nodeId, tigase.xmpp.jid.BareJID jid)
void
setDataSource(tigase.db.DataSource dataSource)
IPubSubDAO
takeDao(tigase.xmpp.jid.BareJID serviceJid)
void
updateNodeAffiliation(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String nodeName, UsersAffiliation affiliation)
void
updateNodeConfig(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String serializedData, T collectionId)
void
updateNodeSubscription(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String nodeName, UsersSubscription subscription)
void
writeItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, long timeInMilis, java.lang.String id, java.lang.String publisher, tigase.xml.Element item, java.lang.String uuid)
-
Methods inherited from class tigase.db.beans.MDRepositoryBeanWithStatistics
everyHour, everyMinute, everySecond, getRepositories, getRepository, getStatistics, setStatisticsEnabled, updateDataSourceAware, wrapInProxy
-
-
-
-
Method Detail
-
belongsTo
public boolean belongsTo(java.lang.Class<? extends tigase.server.BasicComponent> component)
- Specified by:
belongsTo
in interfacetigase.stats.ComponentStatisticsProvider
-
createNode
public T createNode(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName, tigase.xmpp.jid.BareJID ownerJid, AbstractNodeConfig nodeConfig, NodeType nodeType, T collectionId, boolean autocreateService) throws tigase.component.exceptions.RepositoryException
- Specified by:
createNode
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
createService
public void createService(tigase.xmpp.jid.BareJID serviceJID, boolean isPublic) throws tigase.component.exceptions.RepositoryException
- Specified by:
createService
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getServices
public java.util.List<tigase.xmpp.jid.BareJID> getServices(tigase.xmpp.jid.BareJID domain, java.lang.Boolean isPublic) throws tigase.component.exceptions.RepositoryException
- Specified by:
getServices
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
deleteItem
public void deleteItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String id) throws tigase.component.exceptions.RepositoryException
- Specified by:
deleteItem
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
deleteNode
public void deleteNode(tigase.xmpp.jid.BareJID serviceJid, T nodeId) throws tigase.component.exceptions.RepositoryException
- Specified by:
deleteNode
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
destroy
public void destroy()
-
getAllNodesList
public java.lang.String[] getAllNodesList(tigase.xmpp.jid.BareJID serviceJid) throws tigase.component.exceptions.RepositoryException
- Specified by:
getAllNodesList
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getChildNodes
public java.lang.String[] getChildNodes(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName) throws tigase.component.exceptions.RepositoryException
- Specified by:
getChildNodes
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getItem
public IItems.IItem getItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String id) throws tigase.component.exceptions.RepositoryException
-
getItems
public java.util.List<IItems.IItem> getItems(tigase.xmpp.jid.BareJID serviceJid, java.util.List<T> nodesIds, java.util.Date after, java.util.Date before, tigase.xmpp.rsm.RSM rsm, CollectionItemsOrdering ordering) throws tigase.component.exceptions.RepositoryException
-
getItemsIds
public java.lang.String[] getItemsIds(tigase.xmpp.jid.BareJID serviceJid, T nodeId, CollectionItemsOrdering order) throws tigase.component.exceptions.RepositoryException
- Specified by:
getItemsIds
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getItemsIdsSince
public java.lang.String[] getItemsIdsSince(tigase.xmpp.jid.BareJID serviceJid, T nodeId, CollectionItemsOrdering order, java.util.Date since) throws tigase.component.exceptions.RepositoryException
- Specified by:
getItemsIdsSince
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getItemsMeta
public java.util.List<IItems.ItemMeta> getItemsMeta(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String nodeName) throws tigase.component.exceptions.RepositoryException
- Specified by:
getItemsMeta
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getNodeAffiliations
public java.util.Map<tigase.xmpp.jid.BareJID,UsersAffiliation> getNodeAffiliations(tigase.xmpp.jid.BareJID serviceJid, T nodeId) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodeAffiliations
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getNodeMeta
public INodeMeta<T> getNodeMeta(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodeMeta
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getNodesCount
public long getNodesCount(tigase.xmpp.jid.BareJID serviceJid) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodesCount
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getNodesList
public java.lang.String[] getNodesList(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodesList
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getNodeSubscriptions
public java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription> getNodeSubscriptions(tigase.xmpp.jid.BareJID serviceJid, T nodeId) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodeSubscriptions
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getUserAffiliations
public java.util.Map<java.lang.String,UsersAffiliation> getUserAffiliations(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid) throws tigase.component.exceptions.RepositoryException
- Specified by:
getUserAffiliations
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getUserRoster
public java.util.Map<tigase.xmpp.jid.BareJID,tigase.xmpp.impl.roster.RosterElement> getUserRoster(tigase.xmpp.jid.BareJID owner) throws tigase.component.exceptions.RepositoryException
- Specified by:
getUserRoster
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
getUserSubscriptions
public java.util.Map<java.lang.String,UsersSubscription> getUserSubscriptions(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid) throws tigase.component.exceptions.RepositoryException
- Specified by:
getUserSubscriptions
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
parseConfig
public AbstractNodeConfig parseConfig(java.lang.String nodeName, java.lang.String cfgData) throws tigase.component.exceptions.RepositoryException
- Specified by:
parseConfig
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
addMAMItem
public void addMAMItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String uuid, tigase.xml.Element message, java.lang.String itemId) throws tigase.component.exceptions.RepositoryException
- Specified by:
addMAMItem
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
queryItems
public void queryItems(Q query, T nodeId, tigase.xmpp.mam.MAMRepository.ItemHandler<Q,tigase.xmpp.mam.MAMRepository.Item> itemHandler) throws tigase.component.exceptions.RepositoryException, tigase.component.exceptions.ComponentException
- Specified by:
queryItems
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
tigase.component.exceptions.ComponentException
-
removeNodeSubscription
public void removeNodeSubscription(tigase.xmpp.jid.BareJID serviceJid, T nodeId, tigase.xmpp.jid.BareJID jid) throws tigase.component.exceptions.RepositoryException
- Specified by:
removeNodeSubscription
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
takeDao
public IPubSubDAO takeDao(tigase.xmpp.jid.BareJID serviceJid)
-
updateNodeAffiliation
public void updateNodeAffiliation(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String nodeName, UsersAffiliation affiliation) throws tigase.component.exceptions.RepositoryException
- Specified by:
updateNodeAffiliation
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
updateNodeConfig
public void updateNodeConfig(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String serializedData, T collectionId) throws tigase.component.exceptions.RepositoryException
- Specified by:
updateNodeConfig
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
updateNodeSubscription
public void updateNodeSubscription(tigase.xmpp.jid.BareJID serviceJid, T nodeId, java.lang.String nodeName, UsersSubscription subscription) throws tigase.component.exceptions.RepositoryException
- Specified by:
updateNodeSubscription
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
writeItem
public void writeItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, long timeInMilis, java.lang.String id, java.lang.String publisher, tigase.xml.Element item, java.lang.String uuid) throws tigase.component.exceptions.RepositoryException
-
deleteService
public void deleteService(tigase.xmpp.jid.BareJID serviceJid) throws tigase.component.exceptions.RepositoryException
- Specified by:
deleteService
in interfaceIPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>
- Throws:
tigase.component.exceptions.RepositoryException
-
setDataSource
public void setDataSource(tigase.db.DataSource dataSource)
- Specified by:
setDataSource
in interfacetigase.db.DataSourceAware<T>
-
getDefaultBeanClass
public java.lang.Class<?> getDefaultBeanClass()
- Specified by:
getDefaultBeanClass
in interfacetigase.kernel.beans.RegistrarBeanWithDefaultBeanClass
-
getPoolDetails
@Deprecated protected java.lang.String getPoolDetails(tigase.xmpp.jid.BareJID serviceJid)
Deprecated.
-
offerDao
@Deprecated protected void offerDao(tigase.xmpp.jid.BareJID serviceJid, IPubSubDAO dao)
Deprecated.
-
findClassForDataSource
protected java.lang.Class<? extends IPubSubDAO<T,S,Q>> findClassForDataSource(tigase.db.DataSource dataSource) throws tigase.db.DBInitException
- Specified by:
findClassForDataSource
in classtigase.db.beans.MDRepositoryBean<IPubSubDAO<T,S extends tigase.db.DataSource,Q extends Query>>
- Throws:
tigase.db.DBInitException
-
-