Class UnifiedArchivePlugin
java.lang.Object
tigase.xmpp.XMPPProcessor
tigase.xmpp.impl.annotation.AnnotatedXMPPProcessor
tigase.archive.unified.processors.UnifiedArchivePlugin
- All Implemented Interfaces:
Comparable<tigase.xmpp.XMPPImplIfc>
,tigase.xmpp.XMPPImplIfc
,tigase.xmpp.XMPPProcessorConcurrencyAwareIfc
,tigase.xmpp.XMPPProcessorIfc
@Bean(name="unified-archive",
parent=tigase.server.xmppsession.SessionManager.class,
active=false)
public class UnifiedArchivePlugin
extends tigase.xmpp.impl.annotation.AnnotatedXMPPProcessor
implements tigase.xmpp.XMPPProcessorIfc
- Author:
- andrzej
-
Field Summary
Modifier and TypeFieldDescriptionprotected static final String
protected tigase.archive.processors.MessageArchivePlugin
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 TypeMethodDescriptionid()
void
process
(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, tigase.db.NonAuthUserRepository nonAuthUserRepository, Queue<tigase.server.Packet> results, Map<String, Object> map) void
setComponentJid
(tigase.xmpp.jid.JID componentJid) void
setFlexibleOfflineMessageRetrievalRepository
(JDBCFlexibleOfflineMessageRetrievalRepository flexibleOfflineMessageRetrievalRepository) void
setMessageArchivePlugin
(tigase.archive.processors.MessageArchivePlugin messageArchivePlugin) protected void
protected void
Methods inherited from class tigase.xmpp.impl.annotation.AnnotatedXMPPProcessor
supDiscoFeatures, supElementNamePaths, supNamespaces, supStreamFeatures, supTypes
Methods inherited from class tigase.xmpp.XMPPProcessor
canHandle, compareTo, concurrentQueuesNo, getComponentInfo, getInstance, getQueueSize, getStatistics, getThreadsNo, init, 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, concurrentQueuesNo, getComponentInfo, getStatistics, init, supDiscoFeatures, supElementNamePaths, supNamespaces, supStreamFeatures, supTypes
-
Field Details
-
ID
- See Also:
-
messageArchivePlugin
@Inject protected tigase.archive.processors.MessageArchivePlugin messageArchivePlugin -
flexibleOfflineMessageRetrievalRepository
@Inject(nullAllowed=true) protected JDBCFlexibleOfflineMessageRetrievalRepository flexibleOfflineMessageRetrievalRepository
-
-
Constructor Details
-
UnifiedArchivePlugin
public UnifiedArchivePlugin()
-
-
Method Details
-
setMessageArchivePlugin
public void setMessageArchivePlugin(tigase.archive.processors.MessageArchivePlugin messageArchivePlugin) -
setComponentJid
public void setComponentJid(tigase.xmpp.jid.JID componentJid) -
getFlexibleOfflineMessageRetrievalRepository
-
setFlexibleOfflineMessageRetrievalRepository
public void setFlexibleOfflineMessageRetrievalRepository(JDBCFlexibleOfflineMessageRetrievalRepository flexibleOfflineMessageRetrievalRepository) -
id
- Specified by:
id
in interfacetigase.xmpp.XMPPImplIfc
- Overrides:
id
in classtigase.xmpp.impl.annotation.AnnotatedXMPPProcessor
-
process
public void process(tigase.server.Packet packet, tigase.xmpp.XMPPResourceConnection session, tigase.db.NonAuthUserRepository nonAuthUserRepository, Queue<tigase.server.Packet> results, Map<String, Object> map) throws tigase.xmpp.XMPPException- Specified by:
process
in interfacetigase.xmpp.XMPPProcessorIfc
- Throws:
tigase.xmpp.XMPPException
-
updateComponentJid
protected void updateComponentJid() -
updateArchiveOffline
protected void updateArchiveOffline()
-