Package tigase.mix.model
Class MixRepository<T>
java.lang.Object
tigase.mix.model.MixRepository<T>
- All Implemented Interfaces:
IMixRepository
,tigase.pubsub.repository.cached.CachedPubSubRepository.NodeAffiliationProvider<T>
,tigase.pubsub.repository.IItems.IListnener
,tigase.pubsub.repository.IPubSubRepository.IListener
@Bean(name="mixRepository",
parent=MixComponent.class,
active=true)
public class MixRepository<T>
extends Object
implements IMixRepository, tigase.pubsub.repository.IPubSubRepository.IListener, tigase.pubsub.repository.cached.CachedPubSubRepository.NodeAffiliationProvider<T>
-
Nested Class Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
bannedParticipantFromChannel
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantJID) getAllowed
(tigase.xmpp.jid.BareJID channelJID) getBanned
(tigase.xmpp.jid.BareJID channelJID) getChannelConfiguration
(tigase.xmpp.jid.BareJID channelJID) getChannelName
(tigase.xmpp.jid.BareJID channelJID) tigase.pubsub.repository.ISubscriptions
getNodeSubscriptions
(tigase.xmpp.jid.BareJID serviceJid, String nodeName) protected IParticipant
getParticipant
(tigase.xmpp.jid.BareJID channelJID, String participantId) getParticipant
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantRealJID) getUserAffiliations
(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid) protected void
invalidateChannelParticipant
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantId) void
itemDeleted
(tigase.xmpp.jid.BareJID serviceJID, String node, String id) void
itemWritten
(tigase.xmpp.jid.BareJID serviceJID, String node, String id, String publisher, tigase.xml.Element item, String uuid) protected ChannelConfiguration
loadChannelConfiguration
(tigase.xmpp.jid.BareJID channelJID) tigase.pubsub.repository.cached.IAffiliationsCached
newNodeAffiliations
(tigase.xmpp.jid.BareJID serviceJid, String nodeName, T nodeId, tigase.pubsub.repository.IPubSubRepository.RepositorySupplier<Map<tigase.xmpp.jid.BareJID, tigase.pubsub.repository.stateless.UsersAffiliation>> affiliationSupplier) void
removeParticiapnt
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantJID) void
removeTempParticipant
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.JID participantJID) void
serviceRemoved
(tigase.xmpp.jid.BareJID userJid) protected void
updateChannelConfiguration
(tigase.xmpp.jid.BareJID serviceJID, tigase.xml.Element item) updateParticipant
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantJID, String nick) updateTempParticipant
(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.JID participantJID, String nick) boolean
validateItem
(tigase.xmpp.jid.BareJID serviceJID, String node, String id, String publisher, tigase.xml.Element item)
-
Constructor Details
-
MixRepository
public MixRepository()
-
-
Method Details
-
getAllowed
public Optional<List<tigase.xmpp.jid.BareJID>> getAllowed(tigase.xmpp.jid.BareJID channelJID) throws tigase.component.exceptions.RepositoryException - Specified by:
getAllowed
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
getBanned
public Optional<List<tigase.xmpp.jid.BareJID>> getBanned(tigase.xmpp.jid.BareJID channelJID) throws tigase.component.exceptions.RepositoryException - Specified by:
getBanned
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
getParticipant
public IParticipant getParticipant(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantRealJID) throws tigase.component.exceptions.RepositoryException - Specified by:
getParticipant
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
getParticipant
public IParticipant getParticipant(tigase.xmpp.jid.BareJID channelJID, String participantId) throws tigase.component.exceptions.RepositoryException - Specified by:
getParticipant
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
getParticipant
protected IParticipant getParticipant(MixRepository.ParticipantKey key) throws tigase.component.exceptions.RepositoryException - Throws:
tigase.component.exceptions.RepositoryException
-
removeParticiapnt
public void removeParticiapnt(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantJID) throws tigase.component.exceptions.RepositoryException - Specified by:
removeParticiapnt
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
updateParticipant
public IParticipant updateParticipant(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantJID, String nick) throws tigase.component.exceptions.RepositoryException, tigase.pubsub.exceptions.PubSubException - Specified by:
updateParticipant
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
tigase.pubsub.exceptions.PubSubException
-
updateTempParticipant
public IParticipant updateTempParticipant(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.JID participantJID, String nick) throws tigase.component.exceptions.RepositoryException, tigase.pubsub.exceptions.PubSubException - Specified by:
updateTempParticipant
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
tigase.pubsub.exceptions.PubSubException
-
removeTempParticipant
public void removeTempParticipant(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.JID participantJID) throws tigase.component.exceptions.RepositoryException - Specified by:
removeTempParticipant
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
getChannelName
public String getChannelName(tigase.xmpp.jid.BareJID channelJID) throws tigase.component.exceptions.RepositoryException - Specified by:
getChannelName
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
getChannelConfiguration
public ChannelConfiguration getChannelConfiguration(tigase.xmpp.jid.BareJID channelJID) throws tigase.component.exceptions.RepositoryException - Specified by:
getChannelConfiguration
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
loadChannelConfiguration
protected ChannelConfiguration loadChannelConfiguration(tigase.xmpp.jid.BareJID channelJID) throws tigase.component.exceptions.RepositoryException - Throws:
tigase.component.exceptions.RepositoryException
-
getNodeSubscriptions
public tigase.pubsub.repository.ISubscriptions getNodeSubscriptions(tigase.xmpp.jid.BareJID serviceJid, String nodeName) throws tigase.component.exceptions.RepositoryException - Specified by:
getNodeSubscriptions
in interfaceIMixRepository
- Throws:
tigase.component.exceptions.RepositoryException
-
serviceRemoved
public void serviceRemoved(tigase.xmpp.jid.BareJID userJid) - Specified by:
serviceRemoved
in interfacetigase.pubsub.repository.IPubSubRepository.IListener
-
itemDeleted
- Specified by:
itemDeleted
in interfacetigase.pubsub.repository.IItems.IListnener
-
itemWritten
public void itemWritten(tigase.xmpp.jid.BareJID serviceJID, String node, String id, String publisher, tigase.xml.Element item, String uuid) - Specified by:
itemWritten
in interfacetigase.pubsub.repository.IItems.IListnener
-
validateItem
public boolean validateItem(tigase.xmpp.jid.BareJID serviceJID, String node, String id, String publisher, tigase.xml.Element item) throws tigase.pubsub.exceptions.PubSubException - Specified by:
validateItem
in interfacetigase.pubsub.repository.IItems.IListnener
- Throws:
tigase.pubsub.exceptions.PubSubException
-
getUserAffiliations
public Map<String,tigase.pubsub.repository.stateless.UsersAffiliation> getUserAffiliations(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID jid) throws tigase.component.exceptions.RepositoryException - Specified by:
getUserAffiliations
in interfacetigase.pubsub.repository.cached.CachedPubSubRepository.NodeAffiliationProvider<T>
- Throws:
tigase.component.exceptions.RepositoryException
-
newNodeAffiliations
public tigase.pubsub.repository.cached.IAffiliationsCached newNodeAffiliations(tigase.xmpp.jid.BareJID serviceJid, String nodeName, T nodeId, tigase.pubsub.repository.IPubSubRepository.RepositorySupplier<Map<tigase.xmpp.jid.BareJID, tigase.pubsub.repository.stateless.UsersAffiliation>> affiliationSupplier) throws tigase.component.exceptions.RepositoryException- Specified by:
newNodeAffiliations
in interfacetigase.pubsub.repository.cached.CachedPubSubRepository.NodeAffiliationProvider<T>
- Throws:
tigase.component.exceptions.RepositoryException
-
bannedParticipantFromChannel
protected void bannedParticipantFromChannel(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantJID) throws tigase.component.exceptions.RepositoryException - Throws:
tigase.component.exceptions.RepositoryException
-
invalidateChannelParticipant
protected void invalidateChannelParticipant(tigase.xmpp.jid.BareJID channelJID, tigase.xmpp.jid.BareJID participantId) throws tigase.component.exceptions.RepositoryException - Throws:
tigase.component.exceptions.RepositoryException
-
updateChannelConfiguration
protected void updateChannelConfiguration(tigase.xmpp.jid.BareJID serviceJID, tigase.xml.Element item)
-