Package tigase.archive.processors
Class AbstractMAMProcessor
- java.lang.Object
-
- tigase.xmpp.XMPPProcessor
-
- tigase.xmpp.impl.annotation.AnnotatedXMPPProcessor
-
- tigase.archive.processors.AbstractMAMProcessor
-
- All Implemented Interfaces:
java.lang.Comparable<tigase.xmpp.XMPPImplIfc>
,tigase.xmpp.XMPPImplIfc
,tigase.xmpp.XMPPProcessorConcurrencyAwareIfc
,tigase.xmpp.XMPPProcessorIfc
- Direct Known Subclasses:
MAM2Processor
,Xep0313MessageArchiveManagementProcessor
public abstract class AbstractMAMProcessor extends tigase.xmpp.impl.annotation.AnnotatedXMPPProcessor implements tigase.xmpp.XMPPProcessorIfc
Created by andrzej on 22.07.2016.
-
-
Field Summary
Fields Modifier and Type Field Description protected MessageArchivePlugin
messageArchivePlugin
-
Constructor Summary
Constructors Constructor Description AbstractMAMProcessor()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description tigase.xmpp.Authorization
canHandle(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection conn)
protected abstract java.lang.String
getXMLNS()
protected abstract boolean
hasStanzaIdSupport()
void
process(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, tigase.db.NonAuthUserRepository repo, java.util.Queue<tigase.server.Packet> results, java.util.Map<java.lang.String,java.lang.Object> settings)
-
Methods inherited from class tigase.xmpp.impl.annotation.AnnotatedXMPPProcessor
id, supDiscoFeatures, supElementNamePaths, supNamespaces, supStreamFeatures, supTypes
-
Methods inherited from class tigase.xmpp.XMPPProcessor
compareTo, concurrentQueuesNo, getComponentInfo, getInstance, getQueueSize, getStatistics, getThreadsNo, init, toString
-
-
-
-
Field Detail
-
messageArchivePlugin
@Inject protected MessageArchivePlugin messageArchivePlugin
-
-
Method Detail
-
getXMLNS
protected abstract java.lang.String getXMLNS()
-
hasStanzaIdSupport
protected abstract boolean hasStanzaIdSupport()
-
canHandle
public tigase.xmpp.Authorization canHandle(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection conn)
- Specified by:
canHandle
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
canHandle
in classtigase.xmpp.XMPPProcessor
-
process
public void process(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, tigase.db.NonAuthUserRepository repo, java.util.Queue<tigase.server.Packet> results, java.util.Map<java.lang.String,java.lang.Object> settings) throws tigase.xmpp.XMPPException
- Specified by:
process
in interfacetigase.xmpp.XMPPProcessorIfc
- Throws:
tigase.xmpp.XMPPException
-
-