Package tigase.pubsub.repository

Interface IPubSubDAO<T,S extends tigase.db.DataSource,Q extends PubSubQuery>

All Superinterfaces:

tigase.db.DataSourceAware<S>

All Known Subinterfaces:

IExtendedPubSubDAO<T,S,Q>

All Known Implementing Classes:

PubSubDAO, PubSubDAOJDBC, PubSubDAOPool

public interface IPubSubDAO<T,S extends tigase.db.DataSource,Q extends PubSubQuery>
extends tigase.db.DataSourceAware<S>

Interface of database access layer for PubSub component.

Version:

5.0.0, 2010.03.27 at 05:16:25 GMT

Author:

Artur Hefczyc

Method Summary

Modifier and Type	Method	Description
void	addMAMItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, String uuid, tigase.xml.Element message, String itemId)
T	createNode(tigase.xmpp.jid.BareJID serviceJid, 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, String id)
void	deleteNode(tigase.xmpp.jid.BareJID serviceJid, T nodeId)
void	deleteService(tigase.xmpp.jid.BareJID serviceJid)
void	destroy()
String[]	getAllNodesList(tigase.xmpp.jid.BareJID serviceJid)
String[]	getChildNodes(tigase.xmpp.jid.BareJID serviceJid, String nodeName)
IItems.IItem	getItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, String id)
List<IItems.IItem>	getItems(tigase.xmpp.jid.BareJID serviceJid, List<T> nodeIds, Date after, Date before, tigase.xmpp.rsm.RSM rsm, CollectionItemsOrdering ordering)
String[]	getItemsIds(tigase.xmpp.jid.BareJID serviceJid, T nodeId, CollectionItemsOrdering order)
String[]	getItemsIdsSince(tigase.xmpp.jid.BareJID serviceJid, T nodeId, CollectionItemsOrdering order, Date since)
List<IItems.ItemMeta>	getItemsMeta(tigase.xmpp.jid.BareJID serviceJid, T nodeId, String nodeName)
Map<tigase.xmpp.jid.BareJID,UsersAffiliation>	getNodeAffiliations(tigase.xmpp.jid.BareJID serviceJid, T nodeId)
INodeMeta<T>	getNodeMeta(tigase.xmpp.jid.BareJID serviceJid, String nodeName)
long	getNodesCount(tigase.xmpp.jid.BareJID serviceJid)
String[]	getNodesList(tigase.xmpp.jid.BareJID serviceJid, String nodeName)
Map<tigase.xmpp.jid.BareJID,UsersSubscription>	getNodeSubscriptions(tigase.xmpp.jid.BareJID serviceJid, T nodeId)
List<tigase.xmpp.jid.BareJID>	getServices(tigase.xmpp.jid.BareJID domain, Boolean isPublic)
Map<String,UsersAffiliation>	getUserAffiliations(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid)
Map<tigase.xmpp.jid.BareJID,tigase.xmpp.impl.roster.RosterElement>	getUserRoster(tigase.xmpp.jid.BareJID owner)
Map<String,UsersSubscription>	getUserSubscriptions(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid)
default Q	newQuery()	Deprecated.
default Q	newQuery(tigase.xmpp.jid.BareJID serviceJid)
AbstractNodeConfig	parseConfig(String nodeName, 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	updateNodeAffiliation(tigase.xmpp.jid.BareJID serviceJid, T nodeId, String nodeName, UsersAffiliation userAffiliation)
void	updateNodeConfig(tigase.xmpp.jid.BareJID serviceJid, T nodeId, String serializedData, T collectionId)
void	updateNodeSubscription(tigase.xmpp.jid.BareJID serviceJid, T nodeId, String nodeName, UsersSubscription userSubscription)
void	writeItem(tigase.xmpp.jid.BareJID serviceJid, T nodeId, long timeInMilis, String id, String publisher, tigase.xml.Element item, String uuid)

Methods inherited from interface tigase.db.DataSourceAware

setDataSource

Method Details

createNode

T createNode(tigase.xmpp.jid.BareJID serviceJid,
 String nodeName,
 tigase.xmpp.jid.BareJID ownerJid,
 AbstractNodeConfig nodeConfig,
 NodeType nodeType,
 T collectionId,
 boolean autocreateService)
      throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

createService

void createService(tigase.xmpp.jid.BareJID serviceJID,
 boolean isPublic)
            throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

deleteItem

void deleteItem(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String id)
         throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

deleteNode

void deleteNode(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId)
         throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

deleteService

void deleteService(tigase.xmpp.jid.BareJID serviceJid)
            throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

destroy

void destroy()

getServices

List<tigase.xmpp.jid.BareJID> getServices(tigase.xmpp.jid.BareJID domain,
 Boolean isPublic)
                                   throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getAllNodesList

String[] getAllNodesList(tigase.xmpp.jid.BareJID serviceJid)
                  throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getChildNodes

String[] getChildNodes(tigase.xmpp.jid.BareJID serviceJid,
 String nodeName)
                throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getItem

IItems.IItem getItem(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String id)
              throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getItems

List<IItems.IItem> getItems(tigase.xmpp.jid.BareJID serviceJid,
 List<T> nodeIds,
 Date after,
 Date before,
 tigase.xmpp.rsm.RSM rsm,
 CollectionItemsOrdering ordering)
                     throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getItemsIds

String[] getItemsIds(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 CollectionItemsOrdering order)
              throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getItemsIdsSince

String[] getItemsIdsSince(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 CollectionItemsOrdering order,
 Date since)
                   throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getItemsMeta

List<IItems.ItemMeta> getItemsMeta(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String nodeName)
                            throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getNodeAffiliations

Map<tigase.xmpp.jid.BareJID,UsersAffiliation> getNodeAffiliations(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId)
                                                           throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getNodeMeta

INodeMeta<T> getNodeMeta(tigase.xmpp.jid.BareJID serviceJid,
 String nodeName)
                  throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getNodesCount

long getNodesCount(tigase.xmpp.jid.BareJID serviceJid)
            throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getNodesList

String[] getNodesList(tigase.xmpp.jid.BareJID serviceJid,
 String nodeName)
               throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getNodeSubscriptions

Map<tigase.xmpp.jid.BareJID,UsersSubscription> getNodeSubscriptions(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId)
                                                             throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getUserAffiliations

Map<String,UsersAffiliation> getUserAffiliations(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.BareJID jid)
                                          throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getUserRoster

Map<tigase.xmpp.jid.BareJID,tigase.xmpp.impl.roster.RosterElement> getUserRoster(tigase.xmpp.jid.BareJID owner)
                                                                          throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

getUserSubscriptions

Map<String,UsersSubscription> getUserSubscriptions(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.BareJID jid)
                                            throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

parseConfig

AbstractNodeConfig parseConfig(String nodeName,
 String cfgData)
                        throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

addMAMItem

void addMAMItem(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String uuid,
 tigase.xml.Element message,
 String itemId)
         throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

newQuery

@Deprecated
default Q newQuery()

Deprecated.

newQuery

default Q newQuery(tigase.xmpp.jid.BareJID serviceJid)

queryItems

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

Throws:

tigase.component.exceptions.RepositoryException

tigase.component.exceptions.ComponentException

removeNodeSubscription

void removeNodeSubscription(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 tigase.xmpp.jid.BareJID jid)
                     throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

updateNodeAffiliation

void updateNodeAffiliation(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String nodeName,
 UsersAffiliation userAffiliation)
                    throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

updateNodeConfig

void updateNodeConfig(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String serializedData,
 T collectionId)
               throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

updateNodeSubscription

void updateNodeSubscription(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 String nodeName,
 UsersSubscription userSubscription)
                     throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

writeItem

void writeItem(tigase.xmpp.jid.BareJID serviceJid,
 T nodeId,
 long timeInMilis,
 String id,
 String publisher,
 tigase.xml.Element item,
 String uuid)
        throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException