Package tigase.pubsub
Class PepPlugin
java.lang.Object
tigase.xmpp.XMPPProcessor
tigase.pubsub.PepPlugin
- All Implemented Interfaces:
Comparable<tigase.xmpp.XMPPImplIfc>
,tigase.xmpp.impl.ServiceDiscovery.AccountServiceProvider
,tigase.xmpp.XMPPImplIfc
,tigase.xmpp.XMPPProcessorConcurrencyAwareIfc
,tigase.xmpp.XMPPProcessorIfc
,tigase.xmpp.XMPPStopListenerIfc
@Bean(name="pep",
parent=tigase.server.xmppsession.SessionManager.class,
active=true)
public class PepPlugin
extends tigase.xmpp.XMPPProcessor
implements tigase.xmpp.XMPPProcessorIfc, tigase.xmpp.XMPPStopListenerIfc, tigase.xmpp.impl.ServiceDiscovery.AccountServiceProvider
Implements PubSub support for every local user account on it's bare jid using local version of PubSub component.
- Author:
- andrzej
-
Field Summary
Modifier and TypeFieldDescriptionprotected static final tigase.xml.Element[]
protected static final String
protected static final String
protected static final String[][]
protected static final String
protected static final String
protected tigase.xmpp.jid.JID
protected boolean
protected static final String[]
Fields inherited from class tigase.xmpp.XMPPProcessor
ALL_NAMES, ALL_PATHS, cmpInfo
Fields inherited from interface tigase.xmpp.XMPPImplIfc
CLIENT_XMLNS
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
protected tigase.xmpp.jid.JID
getPubsubJid
(tigase.xmpp.XMPPResourceConnection session, tigase.xmpp.jid.JID serviceJid) tigase.xmpp.jid.JID
id()
void
process
(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, tigase.db.NonAuthUserRepository repo, Queue<tigase.server.Packet> results, Map<String, Object> settings) protected void
processIq
(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, Queue<tigase.server.Packet> results) protected void
processJabberIqPrivateToPubSubConversion
(tigase.server.Packet packet, tigase.xml.Element queryEl, tigase.xmpp.XMPPResourceConnection session, Consumer<tigase.server.Packet> writer) protected void
processPresence
(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, Queue<tigase.server.Packet> results) void
setJabberIqPrivateProcessor
(tigase.xmpp.impl.JabberIqPrivate jabberIqPrivateProcessor) void
setVcardTempProcessor
(tigase.xmpp.impl.VCardTemp vcardTempProcessor) void
stopped
(tigase.xmpp.XMPPResourceConnection session, Queue<tigase.server.Packet> results, Map<String, Object> settings) tigase.xml.Element[]
supDiscoFeatures
(tigase.xmpp.XMPPResourceConnection session) String[][]
String[]
Set<tigase.xmpp.StanzaType>
supTypes()
Methods inherited from class tigase.xmpp.XMPPProcessor
canHandle, compareTo, getComponentInfo, getInstance, getQueueSize, getStatistics, getThreadsNo, init, supStreamFeatures, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface java.lang.Comparable
compareTo
Methods inherited from interface tigase.xmpp.XMPPImplIfc
canHandle, getComponentInfo, getStatistics, init, supStreamFeatures
-
Field Details
-
PUBSUB_XMLNS
- See Also:
-
PUBSUB_XMLNS_OWNER
- See Also:
-
DISCO_FEATURES
protected static final tigase.xml.Element[] DISCO_FEATURES -
DISCO_INFO_XMLNS
- See Also:
-
DISCO_ITEMS_XMLNS
- See Also:
-
ELEMENTS
-
XMLNSS
-
simpleNodes
-
pubsubJid
@ConfigField(desc="PubSub Component JID", alias="pubsub-jid") protected tigase.xmpp.jid.JID pubsubJid -
simplePepEnabled
@ConfigField(desc="Enable simple PEP", alias="simple-pep-enabled") protected boolean simplePepEnabled
-
-
Constructor Details
-
PepPlugin
public PepPlugin()
-
-
Method Details
-
id
- Specified by:
id
in interfacetigase.xmpp.XMPPImplIfc
-
concurrentQueuesNo
public int concurrentQueuesNo()- Specified by:
concurrentQueuesNo
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
concurrentQueuesNo
in classtigase.xmpp.XMPPProcessor
-
process
public void process(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, tigase.db.NonAuthUserRepository repo, Queue<tigase.server.Packet> results, Map<String, Object> settings) throws tigase.xmpp.XMPPException- Specified by:
process
in interfacetigase.xmpp.XMPPProcessorIfc
- Throws:
tigase.xmpp.XMPPException
-
setJabberIqPrivateProcessor
public void setJabberIqPrivateProcessor(tigase.xmpp.impl.JabberIqPrivate jabberIqPrivateProcessor) -
setVcardTempProcessor
public void setVcardTempProcessor(tigase.xmpp.impl.VCardTemp vcardTempProcessor) -
supDiscoFeatures
public tigase.xml.Element[] supDiscoFeatures(tigase.xmpp.XMPPResourceConnection session) - Specified by:
supDiscoFeatures
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
supDiscoFeatures
in classtigase.xmpp.XMPPProcessor
-
supElementNamePaths
- Specified by:
supElementNamePaths
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
supElementNamePaths
in classtigase.xmpp.XMPPProcessor
-
supNamespaces
- Specified by:
supNamespaces
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
supNamespaces
in classtigase.xmpp.XMPPProcessor
-
supTypes
- Specified by:
supTypes
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
supTypes
in classtigase.xmpp.XMPPProcessor
-
stopped
public void stopped(tigase.xmpp.XMPPResourceConnection session, Queue<tigase.server.Packet> results, Map<String, Object> settings) - Specified by:
stopped
in interfacetigase.xmpp.XMPPStopListenerIfc
-
getServiceProviderComponentJid
public tigase.xmpp.jid.JID getServiceProviderComponentJid()- Specified by:
getServiceProviderComponentJid
in interfacetigase.xmpp.impl.ServiceDiscovery.AccountServiceProvider
-
getPubsubJid
protected tigase.xmpp.jid.JID getPubsubJid(tigase.xmpp.XMPPResourceConnection session, tigase.xmpp.jid.JID serviceJid) -
processIq
protected void processIq(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, Queue<tigase.server.Packet> results) throws tigase.xmpp.XMPPException - Throws:
tigase.xmpp.XMPPException
-
processPresence
protected void processPresence(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, Queue<tigase.server.Packet> results) throws tigase.xmpp.NotAuthorizedException - Throws:
tigase.xmpp.NotAuthorizedException
-
processJabberIqPrivateToPubSubConversion
protected void processJabberIqPrivateToPubSubConversion(tigase.server.Packet packet, tigase.xml.Element queryEl, tigase.xmpp.XMPPResourceConnection session, Consumer<tigase.server.Packet> writer) throws tigase.xmpp.PacketErrorTypeException, tigase.xmpp.NotAuthorizedException - Throws:
tigase.xmpp.PacketErrorTypeException
tigase.xmpp.NotAuthorizedException
-