Uses of Class
tigase.server.Packet
Package
Description
The main package with top level API for server side components.
Package containing implementation of all Session Manager plugins
-
Uses of Packet in tigase.auth
Modifier and TypeMethodDescriptionvoid
BruteForceLockerBean.BruteForceLockerVHostExtension.addCommandFields
(String prefix, Packet packet, boolean forDefault) void
BruteForceLockerBean.BruteForceLockerVHostExtension.initFromCommand
(String prefix, Packet packet) -
Uses of Packet in tigase.cluster
Modifier and TypeMethodDescriptionClusterConnectionManager.processSocketData
(XMPPIOService<Object> serv) Modifier and TypeMethodDescriptionboolean
SessionManagerClustered.fastAddOutPacket
(Packet packet) protected void
AmpComponentClustered.forwardPacket
(Packet packet) SessionManagerClustered.getXMPPResourceConnection
(Packet p) void
SessionManagerClustered.handleLocalPacket
(Packet packet, XMPPResourceConnection conn) int
ClusterConnectionManager.hashCodeForPacket
(Packet packet) void
ClusterConnectionManager.processOutPacket
(Packet packet) void
AmpComponentClustered.processPacket
(Packet packet) void
ClusterConnectionManager.processPacket
(Packet packet) void
ClusterController.processPacket
(Packet packet, Queue<Packet> results) void
SessionManagerClustered.processPacket
(Packet packet) This is the mainPacket
processing method.void
SessionManagerClustered.processPacket
(Packet packet, XMPPResourceConnection conn) void
VirtualComponent.processPacket
(Packet packet, Queue<Packet> results) boolean
ClusterConnectionManager.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) ClusterConnectionSelector.selectConnection
(Packet p, ClusterConnection conn) ClusterConnectionSelectorOld.selectConnection
(Packet p, ClusterConnection conn) protected boolean
ClusterConnectionManager.writePacketToSocket
(Packet p) Modifier and TypeMethodDescriptionvoid
ClusterController.processPacket
(Packet packet, Queue<Packet> results) void
VirtualComponent.processPacket
(Packet packet, Queue<Packet> results) -
Uses of Packet in tigase.cluster.api
Modifier and TypeMethodDescriptionvoid
ClusterElement.addDataPacket
(Packet packet) boolean
SessionManagerClusteredIfc.fastAddOutPacket
(Packet packet) SessionManagerClusteredIfc.getXMPPResourceConnection
(Packet el_packet) int
ClusterConnectionHandler.hashCodeForPacket
(Packet packet) Generates hashCode for particular packet used to spread processing between thread or connectionsvoid
SessionManagerClusteredIfc.processPacket
(Packet el_packet, XMPPResourceConnection conn) ClusterConnectionSelectorIfc.selectConnection
(Packet packet, ClusterConnection conn) Method returns XMPPIOService instances which should be used to send packet between cluster nodes -
Uses of Packet in tigase.cluster.repo
Modifier and TypeMethodDescriptionvoid
ClusterRepoItem.addCommandFields
(Packet packet) void
ClusterRepoItem.initFromCommand
(Packet packet) -
Uses of Packet in tigase.cluster.strategy
Modifier and TypeMethodDescriptionDefaultClusteringStrategyAbstract.getNodesForIqResponse
(Packet packet) DefaultClusteringStrategy.getNodesForPacketForward
(JID fromNode, Set<JID> visitedNodes, Packet packet) DefaultClusteringStrategyAbstract.getNodesForPacketForward
(JID fromNode, Set<JID> visitedNodes, Packet packet) SMNonCachingAllNodes.getNodesForPacketForward
(JID fromNode, Set<JID> visitedNodes, Packet packet) void
ClusteringStrategyIfc.handleLocalPacket
(Packet packet, XMPPResourceConnection conn) void
DefaultClusteringStrategy.handleLocalPacket
(Packet packet, XMPPResourceConnection conn) void
DefaultClusteringStrategyAbstract.handleLocalPacket
(Packet packet, XMPPResourceConnection conn) boolean
DefaultClusteringStrategyAbstract.isIqResponseToNode
(Packet packet) protected boolean
DefaultClusteringStrategyAbstract.isSuitableForForward
(Packet packet) protected boolean
SMNonCachingAllNodes.isSuitableForForward
(Packet packet) boolean
ClusteringStrategyIfc.processPacket
(Packet packet, XMPPResourceConnection conn) boolean
DefaultClusteringStrategyAbstract.processPacket
(Packet packet, XMPPResourceConnection conn) boolean
DefaultClusteringStrategyAbstract.sendToNextNode
(JID fromNode, Set<JID> visitedNodes, Map<String, String> data, Packet packet) Method attempts to send the packet to the next cluster node. -
Uses of Packet in tigase.component
Modifier and TypeMethodDescriptionprotected void
AbstractComponent.addOutPacket
(Packet packet, AsyncCallback asyncCallback) Deprecated.void
AbstractComponent.processPacket
(Packet packet) Deprecated.void
AbstractKernelBasedComponent.processPacket
(Packet packet) boolean
ComponenScriptCommandProcessor.processScriptCommand
(Packet pc, Queue<Packet> results) void
void
AbstractComponent.DefaultPacketWriter.write
(Packet packet, AsyncCallback callback) void
void
AbstractKernelBasedComponent.DefaultPacketWriter.write
(Packet packet, AsyncCallback callback) void
Writes single Packet.void
PacketWriter.write
(Packet packet, AsyncCallback callback) Modifier and TypeMethodDescriptionboolean
ComponenScriptCommandProcessor.processScriptCommand
(Packet pc, Queue<Packet> results) void
AbstractComponent.DefaultPacketWriter.write
(Collection<Packet> elements) void
AbstractKernelBasedComponent.DefaultPacketWriter.write
(Collection<Packet> elements) void
PacketWriter.write
(Collection<Packet> packets) Writes collection of Packets. -
Uses of Packet in tigase.component.adhoc
-
Uses of Packet in tigase.component.modules
Modifier and TypeMethodDescriptiondefault boolean
Returns true if Packet can be procesed by module.void
Process incoming stanza.void
StanzaProcessor.processPacket
(Packet packet) void
StanzaProcessor.sendException
(Packet packet, ComponentException e) ConvertsComponentException
to XMPP error stanza and sends it to sender of packet.protected boolean
StanzaProcessor.shouldSendException
(Packet packet) protected void
protected void
AbstractModule.write
(Packet packet, AsyncCallback asyncCallback) -
Uses of Packet in tigase.component.modules.impl
Modifier and TypeMethodDescriptionprotected Packet
DiscoveryModule.prepareDiscoInfoReponse
(Packet packet, JID jid, String node, JID senderJID) Deprecated.protected Packet
DiscoveryModule.prepareDiscoInfoResponse
(Packet packet, JID jid, String node, JID senderJID) Modifier and TypeMethodDescriptionprotected Packet
DiscoveryModule.prepareDiscoInfoReponse
(Packet packet, JID jid, String node, JID senderJID) Deprecated.protected Packet
DiscoveryModule.prepareDiscoInfoResponse
(Packet packet, JID jid, String node, JID senderJID) void
void
void
void
protected void
DiscoveryModule.processAdHocCommandItems
(Packet packet, JID jid, String node, JID senderJID) protected void
DiscoveryModule.processDiscoInfo
(Packet packet, JID jid, String node, JID senderJID) protected void
DiscoveryModule.processDiscoItems
(Packet packet, JID jid, String node, JID senderJID) protected void
AdHocCommandModule.processScriptAdHoc
(Packet packet) boolean
AdHocCommandModule.ScriptCommandProcessor.processScriptCommand
(Packet pc, Queue<Packet> results) Modifier and TypeMethodDescriptionboolean
AdHocCommandModule.ScriptCommandProcessor.processScriptCommand
(Packet pc, Queue<Packet> results) -
Uses of Packet in tigase.component.responses
Modifier and TypeMethodDescriptionResponseManager.getResponseHandler
(Packet element) Returns handler for response of sent<iq/>
stanza.void
Called when received response has type error.void
Called when received response has type result.ResponseManager.registerResponseHandler
(Packet stanza, Long timeout, AsyncCallback callback) Register callback for response of sent<iq/>
stanza. -
Uses of Packet in tigase.conf
Modifier and TypeMethodDescriptionvoid
ConfigItem.addCommandFields
(Packet packet) void
ConfigItem.initFromCommand
(Packet packet) void
ConfiguratorOld.processPacket
(Packet packet, Queue<Packet> results) ConfiguratorOld.setPropertyValue
(String key, String val, Packet result_pack, boolean admin) Modifier and TypeMethodDescriptionvoid
ConfiguratorOld.processPacket
(Packet packet, Queue<Packet> results) void
SetLoggingCommand.runCommand
(Iq packet, Bindings binds, Queue<Packet> results) -
Uses of Packet in tigase.db.comp
Modifier and TypeMethodDescriptionvoid
RepositoryItem.addCommandFields
(Packet packet) The method is used for handling ad-hoc commands.void
RepositoryItemAbstract.addCommandFields
(Packet packet) void
RepositoryItem.initFromCommand
(Packet packet) The method used for handling ad-hoc commands.void
RepositoryItemAbstract.initFromCommand
(Packet packet) -
Uses of Packet in tigase.disco
Modifier and TypeMethodDescriptionvoid
XMPPServiceCollector.processPacket
(Packet packet, Queue<Packet> results) Modifier and TypeMethodDescriptionvoid
XMPPServiceCollector.processPacket
(Packet packet, Queue<Packet> results) -
Uses of Packet in tigase.eventbus.component
Modifier and TypeMethodDescriptionvoid
void
void
void
protected Element
SubscribeModule.processClusterSubscription
(Packet packet) protected void
EventbusDiscoveryModule.processDiscoInfo
(Packet packet, JID jid, String node, JID senderJID) protected void
EventbusDiscoveryModule.processDiscoItems
(Packet packet, JID jid, String node, JID senderJID) protected Element
SubscribeModule.processNonClusterSubscription
(Packet packet) void
EventBusComponent.processPacket
(Packet packet) -
Uses of Packet in tigase.io
Modifier and TypeMethodDescriptionvoid
SSLContextContainer.HardenedModeVHostItemExtension.addCommandFields
(String prefix, Packet packet, boolean forDefault) void
SSLContextContainer.HardenedModeVHostItemExtension.initFromCommand
(String prefix, Packet packet) -
Uses of Packet in tigase.io.repo
Modifier and TypeMethodDescriptionvoid
CertificateItem.addCommandFields
(Packet packet) void
CertificateItem.initFromCommand
(Packet packet) -
Uses of Packet in tigase.monitor.modules
Modifier and TypeMethodDescriptionvoid
protected void
DiscoveryMonitorModule.processAdHocCommandItems
(Packet packet, JID jid, String node, JID senderJID) protected void
DiscoveryMonitorModule.processDiscoInfo
(Packet packet, JID jid, String node, JID senderJID) protected void
DiscoveryMonitorModule.processDiscoItems
(Packet packet, JID jid, String node, JID senderJID) -
Uses of Packet in tigase.server
Modifier and TypeClassDescriptionclass
Created: Dec 31, 2009 8:43:21 PMclass
Created: Dec 31, 2009 8:38:38 PMclass
Created: Dec 31, 2009 8:42:05 PMModifier and TypeMethodDescriptionIq.commandResult
(Command.DataType cmd_type) static Packet
Iq.commandResultForm
(Iq packet) static Packet
Iq.commandResultResult
(Iq packet) Packet.copyElementOnly()
copyElementOnly
method creates a copy of the packet with stanza information copied only.Packet.errorResult
(String errorType, Integer errorCode, String errorCondition, String errorText, boolean includeOriginalXML) Method returns a modified copy of thePacket
with its stanza as stanza error used for reporting errors.This is the actual packet filtering method.static Packet
Message.getMessage
(JID from, JID to, StanzaType type, String body, String subject, String thread, String id) Creates a packet with message stanza.Command.getPacket
(JID from, JID to, StanzaType type, String id) Method returns instance of a Packet with command element added.Command.getPacket
(JID from, JID to, StanzaType type, String id, Command.DataType data_type) Method returns instance of a Packet with command element added.Method returns a modified copy of thePacket
with its stanza as stanzaresult
used for reporting IQ stanza results.Method returns a modified copy of thePacket
with its stanza as stanzaresult
used for reporting IQ stanza results.static Packet
Packet.packetInstance
(String el_name, String from, String to, StanzaType type) The method creates XML stanza from given parameters and returnsPacket
instance for this XML stanza.static Packet
Packet.packetInstance
(Element elem) The method returnsPacket
instance.static Packet
Packet.packetInstance
(Element elem, JID stanzaFrom, JID stanzaTo) The method returnsPacket
instance.Packet.packRouted()
Returns a newPacket
instance with stanza routed which means an original stanza has been enclosed inside aroute
XML element which contains additional information taken fromPacket
packet instance internal attributes.Packet.swapFromTo()
Creates a newPacket
instance with swapped packet source and destination addresses.Packet.swapFromTo
(Element el, JID stanzaFrom, JID stanzaTo) The method creates a new instance of thePacket
class with the packet source and destination addresses swapped and sets the given stanza element plus source and destination addresses for the new stanza.Packet.swapStanzaFromTo()
The method creates a newPacket
instance with a stanza copy with swapped source and destination addresses.Packet.swapStanzaFromTo
(StanzaType type) The method creates a newPacket
instance with a stanza copy with swapped source and destination addresses and the given type set.Packet.unpackRouted()
The method unpacks the original packet and stanza fromroute
stanza.Modifier and TypeMethodDescriptionstatic void
Command.addAction
(Packet packet, Command.Action action) static void
Command.addCheckBoxField
(Packet packet, String f_name, boolean f_value) void
BasicComponent.ServerInfoVHostItemExtension.addCommandFields
(String prefix, Packet packet, boolean forDefault) static void
Command.addFieldMultiValue
(Packet packet, String f_name, Throwable ex) static void
Command.addFieldMultiValue
(Packet packet, String f_name, List<String> f_value) A simple method for adding a multi-line (text-multi) data field to the command data form.static void
static void
Command.addFieldValue
(Packet packet, String f_name, String f_value) Simple method for adding a new field to the command data form.static void
Command.addFieldValue
(Packet packet, String f_name, String[] f_values, String label, String[] labels, String[] options) This method allows to add a new multi-option-select-many data field to the command data form.static void
Command.addFieldValue
(Packet packet, String f_name, String f_value, String type) static void
static void
Command.addFieldValue
(Packet packet, String f_name, String f_value, String label, String[] labels, String[] options) This method allows to add a new multi-option-select-one data field to the command data form.static void
Command.addFieldValue
(Packet packet, String f_name, String f_value, String label, String[] labels, String[] options, String type) static void
Command.addHiddenField
(Packet packet, String f_name, String f_value) static void
Command.addInstructions
(Packet packet, String instructions) static void
protected boolean
AbstractMessageReceiver.addOutPacket
(Packet packet) protected boolean
AbstractMessageReceiver.addOutPacketNB
(Packet packet) Non blocking version ofaddOutPacket
.boolean
AbstractMessageReceiver.addOutPacketWithTimeout
(Packet packet, Duration timeout, PacketWriterWithTimeout.Handler handler) boolean
AbstractMessageReceiver.addOutPacketWithTimeout
(Packet packet, ReceiverTimeoutHandler handler, long delay, TimeUnit unit) boolean
PacketWriterWithTimeout.addOutPacketWithTimeout
(Packet packet, Duration timeout, PacketWriterWithTimeout.Handler handler) boolean
Method adds aPacket
object to the internal input queue.boolean
boolean
AbstractMessageReceiver.addPacketNB
(Packet packet) This is a variant ofaddPacket(Packet)
method which addsPacket
to in the internal input queue without blocking.boolean
MessageReceiver.addPacketNB
(Packet packet) static void
Command.addTextField
(Packet packet, String f_name, String f_value) static void
This is the actual packet filtering method.static Command.Action
static boolean
Command.getCheckBoxFieldValue
(Packet packet, String f_name) static Element
static String
Command.getFieldKeyStartingWith
(Packet packet, String f_name) static String
Command.getFieldValue
(Packet packet, String f_name) static String
Command.getFieldValue
(Packet packet, String f_name, boolean debug) static String[]
Command.getFieldValues
(Packet packet, String f_name) protected String
ConnectionManager.getServiceId
(Packet packet) protected IO
ConnectionManager.getXMPPIOService
(Packet p) void
int
AbstractMessageReceiver.hashCodeForPacket
(Packet packet) This method decides how incoming packets are distributed among processing threads.int
ConnectionManager.hashCodeForPacket
(Packet packet) int
MessageRouter.hashCodeForPacket
(Packet packet) void
BasicComponent.ServerInfoVHostItemExtension.initFromCommand
(String prefix, Packet packet) boolean
StanzaSourceChecker.isPacketFromConnectionManager
(Packet packet) void
AbstractMessageReceiver.processOutPacket
(Packet packet) By default this method just copies the given packet between queue.abstract void
AbstractMessageReceiver.processPacket
(Packet packet) This is the mainPacket
processing method.final void
AbstractMessageReceiver.processPacket
(Packet packet, Queue<Packet> results) void
BasicComponent.processPacket
(Packet packet, Queue<Packet> results) void
ConnectionManager.processPacket
(Packet packet) void
MessageRouter.processPacket
(Packet packet) void
ServerComponent.processPacket
(Packet packet, Queue<Packet> results) processPacket
is a blocking processing method implemented by all components.void
MessageRouter.processPacketMR
(Packet packet, Queue<Packet> results) boolean
BasicComponent.processScriptCommand
(Packet pc, Queue<Packet> results) abstract boolean
ConnectionManager.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) Processes undelivered packetsstatic boolean
Command.removeFieldValue
(Packet packet, String f_name) void
ReceiverTimeoutHandler.responseReceived
(Packet data, Packet response) static void
static void
static void
Command.setStatus
(Packet packet, Command.Status status) void
ReceiverTimeoutHandler.timeOutExpired
(Packet data) boolean
ConnectionManager.writePacketToSocket
(IO ios, Packet p) protected boolean
ConnectionManager.writePacketToSocket
(Packet p) protected boolean
ConnectionManager.writePacketToSocket
(Packet p, String serviceId) Modifier and TypeMethodDescriptionprotected boolean
AbstractMessageReceiver.addOutPackets
(Queue<Packet> packets) boolean
AbstractMessageReceiver.addPackets
(Queue<Packet> packets) This is a convenience method for adding all packets stored in given queue to the component's internal input queue.
The method callsaddPacket(Packet)
in a loop for each packet in the queue.boolean
MessageReceiver.addPackets
(Queue<Packet> packets) final void
AbstractMessageReceiver.processPacket
(Packet packet, Queue<Packet> results) void
BasicComponent.processPacket
(Packet packet, Queue<Packet> results) void
ServerComponent.processPacket
(Packet packet, Queue<Packet> results) processPacket
is a blocking processing method implemented by all components.void
MessageRouter.processPacketMR
(Packet packet, Queue<Packet> results) boolean
BasicComponent.processScriptCommand
(Packet pc, Queue<Packet> results) void
ConnectionManager.writePacketsToSocket
(IO serv, Queue<Packet> packets) -
Uses of Packet in tigase.server.amp
Modifier and TypeMethodDescriptionprotected Packet
ActionAbstract.prepareAmpPacket
(Packet packet, Element rule) Modifier and TypeMethodDescriptionboolean
ActionResultsHandlerIfc.addOutPacket
(Packet packet) boolean
AmpComponent.addOutPacket
(Packet packet) boolean
boolean
protected Packet
ActionAbstract.prepareAmpPacket
(Packet packet, Element rule) void
AmpComponent.processPacket
(Packet packet) protected void
ActionAbstract.removeTigasePayload
(Packet packet) Modifier and TypeMethodDescriptionboolean
ActionResultsHandlerIfc.addOutPackets
(Queue<Packet> packets) boolean
AmpComponent.addOutPackets
(Queue<Packet> packets) -
Uses of Packet in tigase.server.amp.action
Modifier and TypeMethodDescriptionboolean
boolean
boolean
boolean
boolean
boolean
boolean
Broadcast.preprocess
(Packet packet) -
Uses of Packet in tigase.server.amp.cond
-
Uses of Packet in tigase.server.bosh
Modifier and TypeMethodDescriptionBoshConnectionManager.processSocketData
(XMPPIOService<Object> srv) Modifier and TypeMethodDescriptionboolean
BoshConnectionManager.addOutStreamClosed
(Packet packet, BoshSession bs, boolean withTimeout) boolean
BoshSessionTaskHandler.addOutStreamClosed
(Packet packet, BoshSession bs, boolean withTimeout) boolean
BoshConnectionManager.addOutStreamOpen
(Packet packet, BoshSession bs) boolean
BoshSessionTaskHandler.addOutStreamOpen
(Packet packet, BoshSession bs) protected JID
BoshConnectionManager.changeDataReceiver
(Packet packet, JID newAddress, String command_sessionId, XMPPIOService<Object> serv) BoshConnectionManager.getSeeOtherHostError
(Packet packet, BareJID destination) BoshSessionTaskHandler.getSeeOtherHostError
(Packet packet, BareJID destination) BoshConnectionManager.getSeeOtherHostForJID
(Packet packet, BareJID fromJID, SeeOtherHostIfc.Phase ph) BoshSessionTaskHandler.getSeeOtherHostForJID
(Packet packet, BareJID userId, SeeOtherHostIfc.Phase ph) void
BoshSession.init
(Packet packet, BoshIOService service, long max_wait, long min_polling, long max_inactivity, int concurrent_requests, int hold_requests, long max_pause, int max_batch_size, long batch_queue_timeout, Queue<Packet> out_results) protected void
BoshSession.init
(Packet packet, BoshIOService service, long max_wait, long min_polling, long max_inactivity, int concurrent_requests, int hold_requests, long max_pause, int max_batch_size, long batch_queue_timeout, Queue<Packet> out_results, boolean preBindEnabled) protected void
BoshConnectionManager.processCommand
(Packet packet) void
BoshConnectionManager.processPacket
(Packet packet) void
BoshSession.processPacket
(Packet packet, Queue<Packet> out_results) void
BoshSession.processSocketPacket
(Packet packet, BoshIOService service, Queue<Packet> out_results) boolean
BoshSessionTaskHandler.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) void
BoshIOService.sendErrorAndStop
(Authorization errorCode, StreamError streamError, Packet packet, String errorMsg) protected boolean
BoshConnectionManager.writePacketToSocket
(Packet packet) Modifier and TypeMethodDescriptionprotected void
BoshConnectionManager.addOutPackets
(Queue<Packet> out_results, BoshSession bs) Method adds packets to the output queue stamping it with the appropriateBoshSession
datavoid
BoshSession.init
(Packet packet, BoshIOService service, long max_wait, long min_polling, long max_inactivity, int concurrent_requests, int hold_requests, long max_pause, int max_batch_size, long batch_queue_timeout, Queue<Packet> out_results) protected void
BoshSession.init
(Packet packet, BoshIOService service, long max_wait, long min_polling, long max_inactivity, int concurrent_requests, int hold_requests, long max_pause, int max_batch_size, long batch_queue_timeout, Queue<Packet> out_results, boolean preBindEnabled) void
BoshSession.processPacket
(Packet packet, Queue<Packet> out_results) void
BoshSession.processSocketPacket
(Packet packet, BoshIOService service, Queue<Packet> out_results) boolean
-
Uses of Packet in tigase.server.ext
Modifier and TypeMethodDescriptionvoid
CompRepoItem.addCommandFields
(Packet packet) void
ComponentProtocol.authenticationFailed
(ComponentIOService serv, Packet packet) void
ComponentProtocolHandler.authenticationFailed
(ComponentIOService serv, Packet packet) protected ComponentIOService
ComponentProtocol.getXMPPIOService
(Packet p) void
CompRepoItem.initFromCommand
(Packet packet) boolean
ExtProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
ComponentProtocol.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) void
ExtProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
ComponentProtocol.writePacketToSocket
(ComponentIOService ios, Packet p) Modifier and TypeMethodDescriptionboolean
ExtProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
ExtProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) -
Uses of Packet in tigase.server.ext.handlers
Modifier and TypeMethodDescriptionboolean
BindProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
HandshakeProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
SASLProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
StartTLSProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
StreamFeaturesProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
BindProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
HandshakeProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
SASLProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
StartTLSProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
StreamFeaturesProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) Modifier and TypeMethodDescriptionboolean
BindProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
HandshakeProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
SASLProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
StartTLSProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) boolean
StreamFeaturesProcessor.process
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
BindProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
HandshakeProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
SASLProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
StartTLSProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) void
StreamFeaturesProcessor.startProcessing
(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) -
Uses of Packet in tigase.server.ext.lb
Modifier and TypeMethodDescriptionLoadBalancerIfc.selectConnection
(Packet p, List<ComponentConnection> conns) ReceiverBareJidLB.selectConnection
(Packet p, List<ComponentConnection> conns) ReceiverFullJidLB.selectConnection
(Packet p, List<ComponentConnection> conns) SenderBareJidLB.selectConnection
(Packet p, List<ComponentConnection> conns) SenderFullJidLB.selectConnection
(Packet p, List<ComponentConnection> conns) -
Uses of Packet in tigase.server.extdisco
Modifier and TypeMethodDescriptionvoid
ExtServiceDiscoItem.addCommandFields
(Packet packet) void
ExtServiceDiscoItem.initFromCommand
(Packet packet) void
void
ExternalServiceDiscoveryProcessor.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Modifier and TypeMethodDescriptionvoid
ExternalServiceDiscoveryProcessor.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) -
Uses of Packet in tigase.server.filters
-
Uses of Packet in tigase.server.monitor
-
Uses of Packet in tigase.server.rtbl
Modifier and TypeMethodDescriptionRTBLIqModule.ResultEvent.Result.fromPacket
(Packet packet) void
void
-
Uses of Packet in tigase.server.script
Modifier and TypeMethodDescriptionvoid
AddScriptCommand.runCommand
(Iq packet, Bindings binds, Queue<Packet> results) void
CommandIfc.runCommand
(Iq packet, Bindings binds, Queue<Packet> results) void
RemoveScriptCommand.runCommand
(Iq packet, Bindings binds, Queue<Packet> results) void
Script.runCommand
(Iq packet, Bindings binds, Queue<Packet> results) -
Uses of Packet in tigase.server.test
Modifier and TypeMethodDescriptionint
TestComponent.hashCodeForPacket
(Packet packet) void
void
void
EchoComponent.processPacket
(Packet packet) -
Uses of Packet in tigase.server.websocket
Modifier and TypeMethodDescriptionprotected void
WebSocketXMPPIOService.addReceivedPacket
(Packet packet) -
Uses of Packet in tigase.server.xmppclient
Modifier and TypeMethodDescriptionStreamManagementIOProcessor.OutQueue.Entry.getPacketWithStamp()
Modifier and TypeMethodDescriptionClientConnectionManager.processSocketData
(XMPPIOService<Object> serv) Modifier and TypeMethodDescriptionvoid
ClientTrustManagerFactory.ClientTrustVHostItemExtension.addCommandFields
(String prefix, Packet packet, boolean forDefault) void
SeeOtherHost.SeeOtherHostVHostItemExtension.addCommandFields
(String prefix, Packet packet, boolean forDefault) protected void
C2SIOService.addReceivedPacket
(Packet packet) boolean
Deprecated.boolean
Append packet to waiting for ack queueprotected JID
ClientConnectionManager.changeDataReceiver
(Packet packet, JID newAddress, String command_sessionId, XMPPIOService<Object> serv) protected boolean
RegistrationThrottling.checkLimits
(XMPPIOService service, Packet packet) static StreamManagementCommand
StreamManagementCommand.fromPacket
(Packet packet) int
ClientConnectionManager.hashCodeForPacket
(Packet packet) void
ClientTrustManagerFactory.ClientTrustVHostItemExtension.initFromCommand
(String prefix, Packet packet) void
SeeOtherHost.SeeOtherHostVHostItemExtension.initFromCommand
(String prefix, Packet packet) protected boolean
protected void
ClientConnectionManager.processCommand
(Packet packet) void
RegistrationThrottlingProcessor.processCommand
(XMPPIOService service, Packet packet) void
StreamErrorCounterIOProcessor.processCommand
(XMPPIOService service, Packet packet) void
StreamManagementIOProcessor.processCommand
(XMPPIOService service, Packet pc) void
XMPPIOProcessor.processCommand
(XMPPIOService service, Packet packet) Process command execution which may be sent from other component and should be processed by processorboolean
RegistrationThrottlingProcessor.processIncoming
(XMPPIOService service, Packet packet) boolean
StreamErrorCounterIOProcessor.processIncoming
(XMPPIOService service, Packet packet) boolean
StreamManagementIOProcessor.processIncoming
(XMPPIOService service, Packet packet) boolean
XMPPIOProcessor.processIncoming
(XMPPIOService service, Packet packet) Process packets read from socket as they are sent to SessionManager.boolean
RegistrationThrottlingProcessor.processOutgoing
(XMPPIOService service, Packet packet) boolean
StreamErrorCounterIOProcessor.processOutgoing
(XMPPIOService service, Packet packet) boolean
StreamManagementIOProcessor.processOutgoing
(XMPPIOService service, Packet packet) boolean
XMPPIOProcessor.processOutgoing
(XMPPIOService service, Packet packet) Process outgoing packets as they are added to XMPPIOService outgoing packets queue.void
ClientConnectionManager.processPacket
(Packet packet) boolean
ClientConnectionManager.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) -
Uses of Packet in tigase.server.xmppcomponent
Modifier and TypeMethodDescriptionComponentConnectionManager.processSocketData
(XMPPIOService<Object> serv) Deprecated.Modifier and TypeMethodDescriptionprotected String
ComponentConnectionManager.getServiceId
(Packet packet) Deprecated.void
ComponentConnectionManager.processPacket
(Packet packet) Deprecated.boolean
ComponentConnectionManager.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) Deprecated. -
Uses of Packet in tigase.server.xmppserver
Modifier and TypeMethodDescriptionvoid
S2SConnection.addControlPacket
(Packet packet) boolean
S2SConnectionHandlerIfc.addOutPacket
(Packet packet) boolean
S2SConnectionManager.addOutPacket
(Packet packet) boolean
S2SFilterIfc.filter
(Packet p, S2SIOService serv, Queue<Packet> results) int
S2SConnectionManager.hashCodeForPacket
(Packet packet) boolean
S2SProcessor.process
(Packet p, S2SIOService serv, Queue<Packet> results) void
S2SConnectionManager.processPacket
(Packet packet) boolean
S2SConnectionManager.processUndeliveredPacket
(Packet packet, Long stamp, String errorMessage) S2SConnectionSelector.selectConnection
(Packet packet, Set<S2SConnection> outgoing) S2SRandomSelector.selectConnection
(Packet packet, Set<S2SConnection> outgoing) boolean
CIDConnections.sendControlPacket
(String sessionId, Packet packet) void
CIDConnections.sendHandshakingOnly
(Packet verify_req) void
CIDConnections.sendPacket
(Packet packet) boolean
S2SConnection.sendPacket
(Packet packet) default boolean
S2SProcessor.shouldSkipUndelivered
(Packet packet) Method determines whether not delivered packet (due to closed connection) should be skipped and not added for re-delivery.boolean
S2SConnectionHandlerIfc.writePacketToSocket
(IO serv, Packet packet) Modifier and TypeMethodDescriptionboolean
S2SFilterIfc.filter
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
S2SProcessor.process
(Packet p, S2SIOService serv, Queue<Packet> results) void
S2SConnectionHandlerIfc.writePacketsToSocket
(IO serv, Queue<Packet> packets) -
Uses of Packet in tigase.server.xmppserver.proc
Modifier and TypeMethodDescriptionvoid
AuthenticatorSelectorManager.authenticationFailed
(Packet packet, S2SIOService serv, AuthenticationProcessor processor, Queue<Packet> results) boolean
Dialback.canHandle
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
SaslExternal.canHandle
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
PacketChecker.filter
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StreamFeatures.filter
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
AuthenticatorSelectorManager.isAllowed
(Packet p, S2SIOService serv, AuthenticationProcessor processor, Queue<Packet> results) Method determines if given authenticator is allowed to proceed: takes into consideration authenticators priority, currently used authenticator as well as received stream futuresprotected boolean
PacketChecker.isAllowed
(Packet p, S2SIOService serv, CID cid) Check if incoming packet is allowed on this connectionboolean
Dialback.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
S2SAbstractProcessor.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
SaslExternal.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StartTLS.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StreamError.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StreamFeatures.process
(Packet p, S2SIOService serv, Queue<Packet> results) void
Dialback.restartAuth
(Packet packet, S2SIOService serv, Queue<Packet> results) void
SaslExternal.restartAuth
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
Dialback.shouldSkipUndelivered
(Packet packet) boolean
SaslExternal.shouldSkipUndelivered
(Packet packet) boolean
StartTLS.shouldSkipUndelivered
(Packet packet) boolean
StartZlib.shouldSkipUndelivered
(Packet packet) boolean
StreamFeatures.shouldSkipUndelivered
(Packet packet) Modifier and TypeMethodDescriptionvoid
AuthenticatorSelectorManager.authenticationFailed
(Packet packet, S2SIOService serv, AuthenticationProcessor processor, Queue<Packet> results) boolean
Dialback.canHandle
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
SaslExternal.canHandle
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
PacketChecker.filter
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StreamFeatures.filter
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
AuthenticatorSelectorManager.isAllowed
(Packet p, S2SIOService serv, AuthenticationProcessor processor, Queue<Packet> results) Method determines if given authenticator is allowed to proceed: takes into consideration authenticators priority, currently used authenticator as well as received stream futuresboolean
Dialback.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
S2SAbstractProcessor.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
SaslExternal.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StartTLS.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StreamError.process
(Packet p, S2SIOService serv, Queue<Packet> results) boolean
StreamFeatures.process
(Packet p, S2SIOService serv, Queue<Packet> results) void
Dialback.restartAuth
(Packet packet, S2SIOService serv, Queue<Packet> results) void
SaslExternal.restartAuth
(Packet p, S2SIOService serv, Queue<Packet> results) -
Uses of Packet in tigase.server.xmppsession
Modifier and TypeMethodDescriptionboolean
SessionManager.addOutPacket
(Packet packet) protected void
SessionManager.addOutPackets
(Packet packet, XMPPResourceConnection conn, Queue<Packet> results) void
SessionManager.MessageArchive.addStableId
(Packet packet, XMPPResourceConnection session) boolean
PacketDefaultHandler.canHandle
(Packet packet, XMPPResourceConnection session) Method checks if packet can be processed by this handlerprotected boolean
SessionManager.fastAddOutPacket
(Packet packet) boolean
PacketDefaultHandler.forward
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
SessionManager.MessageArchive.generateStableId
(Packet packet) protected XMPPResourceConnection
SessionManager.getXMPPResourceConnection
(Packet p) void
SessionManager.handleLocalPacket
(Packet packet, XMPPResourceConnection conn) int
SessionManager.hashCodeForPacket
(Packet packet) protected boolean
SessionManager.isBrokenPacket
(Packet p) boolean
PacketDefaultHandler.preprocess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
PacketDefaultHandler.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
SessionManager.DefaultHandlerProc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionManager.SessionCloseProc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionManager.SessionOpenProc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected boolean
SessionManager.processAdminsOrDomains
(Packet packet) protected boolean
SessionManager.processCommand
(Packet pc) void
SessionManager.processPacket
(Packet packet) protected void
SessionManager.processPacket
(Packet packet, XMPPResourceConnection conn) protected void
SessionManager.sendToAdmins
(Packet packet) boolean
SessionManager.MessageArchive.willArchive
(Packet packet, XMPPResourceConnection session) void
SessionManager.ProcessorResultWriter.write
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) void
void
SessionManager.SMPacketWriter.write
(Packet packet, AsyncCallback callback) Modifier and TypeMethodDescriptionprotected void
SessionManager.addOutPackets
(Packet packet, XMPPResourceConnection conn, Queue<Packet> results) boolean
PacketDefaultHandler.forward
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) boolean
PacketDefaultHandler.preprocess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
PacketDefaultHandler.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
SessionManager.DefaultHandlerProc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionManager.SessionCloseProc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionManager.SessionOpenProc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionManager.ProcessorResultWriter.write
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) void
SessionManager.SMPacketWriter.write
(Collection<Packet> packets) -
Uses of Packet in tigase.stats
Modifier and TypeMethodDescriptionvoid
StatisticsCollector.processPacket
(Packet packet, Queue<Packet> results) Modifier and TypeMethodDescriptionvoid
StatisticsCollector.processPacket
(Packet packet, Queue<Packet> results) -
Uses of Packet in tigase.util.processing
Modifier and TypeMethodDescriptionboolean
ProcessingThreads.addItem
(XMPPProcessorIfc processor, Packet packet, XMPPResourceConnection conn) ModifierConstructorDescriptionQueueItem
(XMPPProcessorIfc processor, Packet packet, XMPPResourceConnection conn) -
Uses of Packet in tigase.util.tracer
Modifier and TypeMethodDescriptionboolean
TigaseTracer.trace
(String ip, String to_jid, String from_jid, String cid, String id, String point, String msg, Packet packet) boolean
TigaseTracer.traceByCid
(String cid, String point, String msg, Packet packet) boolean
TigaseTracer.traceByFromJid
(String jid, String point, String msg, Packet packet) boolean
TigaseTracer.traceByToJid
(String jid, String point, String msg, Packet packet) boolean
TigaseTracer.tracegByIP
(String ip, String point, String msg, Packet packet) -
Uses of Packet in tigase.vhosts
Modifier and TypeMethodDescriptionvoid
VHostItemExtensionIfc.addCommandFields
(String prefix, Packet packet, boolean forDefault) Method adds custom extension fields to the ad-hoc form which will be sent to the user for filling with data required to create or update the VHost details.void
VHostItemImpl.addCommandFields
(Packet packet) void
VHostItemImpl.VHostItemWrapper.addCommandFields
(Packet packet) void
VHostItemExtensionIfc.initFromCommand
(String prefix, Packet packet) Method initializes instance of a class with values provided by the user using ad-hoc command.void
VHostItemImpl.initFromCommand
(Packet packet) void
VHostItemImpl.VHostItemWrapper.initFromCommand
(Packet packet) -
Uses of Packet in tigase.xmpp
Modifier and TypeMethodDescriptionAuthorization.getResponseMessage
(Packet packet, String text, boolean includeOriginalXML) Utility method for generating an error response for a stanza (enclosed by the givenPacket
).XMPPProcessorException.makeElement
(Packet packet, boolean insertOriginal) Modifier and TypeMethodDescriptionXMPPIOService.getReceivedPackets()
XMPPIOService.getWaitingForAct()
XMPPIOService.getWaitingPackets()
Returns queue with packets waiting to send.Modifier and TypeMethodDescriptionvoid
XMPPIOService.addPacketToSend
(Packet packet) MethodaddPacketToSend
adds new data which will be processed during next run.protected void
XMPPIOService.addReceivedPacket
(Packet packet) MethodaddReceivedPacket
puts processing results to queue.XMPPImplIfc.canHandle
(Packet packet, XMPPResourceConnection conn) By default the method usesXMPPImplIfc.supElementNamePaths()
andXMPPImplIfc.supTypes()
method results to determine whether the plugin would process given packet.XMPPProcessor.canHandle
(Packet packet, XMPPResourceConnection conn) void
XMPPPacketFilterIfc.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) Authorization.getResponseMessage
(Packet packet, String text, boolean includeOriginalXML) Utility method for generating an error response for a stanza (enclosed by the givenPacket
).static boolean
XMPPProcessorAbstract.isFromUserSession
(Packet packet, XMPPResourceConnection session) static boolean
XMPPProcessorAbstract.isNullSession
(Packet packet, XMPPResourceConnection session) static boolean
XMPPProcessorAbstract.isServerSession
(Packet packet, XMPPResourceConnection session) static boolean
XMPPProcessorAbstract.isToUserSession
(Packet packet, XMPPResourceConnection session) XMPPProcessorException.makeElement
(Packet packet, boolean insertOriginal) boolean
void
XMPPPostprocessorIfc.postProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs processing ofpacket
for which there was no processor.boolean
XMPPPreprocessorIfc.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket
.void
XMPPProcessorAbstract.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
XMPPProcessorIfc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
XMPPProcessorAbstract.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called when a packet is sent from the user, owner of the session somewhere else to other XMPP entity (other user on the server, other user on a different server, different server, component, transport, etc....).void
XMPPProcessorAbstract.processFromUserPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called for all packets sent by the user, owner of this connection/session.abstract void
XMPPProcessorAbstract.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called when a packet is send from the user who is owner of the session to the local server (ping, roster management, privacy lists, etc...).void
XMPPProcessorAbstract.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called for packets received by the server for which no user session is found - neither sender session or receiver session.abstract void
XMPPProcessorAbstract.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called when a packet addressed to the server domain is received.void
XMPPProcessorAbstract.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Method is called for all the packets sent TO the user - owner of the session.protected boolean
XMPPIOService.shouldCountPacket
(Packet packet) Modifier and TypeMethodDescriptionvoid
XMPPPacketFilterIfc.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
XMPPPostprocessorIfc.postProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs processing ofpacket
for which there was no processor.boolean
XMPPPreprocessorIfc.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket
.void
XMPPProcessorAbstract.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
XMPPProcessorIfc.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
XMPPProcessorAbstract.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called when a packet is sent from the user, owner of the session somewhere else to other XMPP entity (other user on the server, other user on a different server, different server, component, transport, etc....).void
XMPPProcessorAbstract.processFromUserPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called for all packets sent by the user, owner of this connection/session.abstract void
XMPPProcessorAbstract.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called when a packet is send from the user who is owner of the session to the local server (ping, roster management, privacy lists, etc...).void
XMPPProcessorAbstract.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called for packets received by the server for which no user session is found - neither sender session or receiver session.abstract void
XMPPProcessorAbstract.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) The method is called when a packet addressed to the server domain is received.void
XMPPProcessorAbstract.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Method is called for all the packets sent TO the user - owner of the session.void
XMPPStopListenerIfc.stopped
(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Performs additional processing upon closing user session (user either disconnects or logs-out). -
Uses of Packet in tigase.xmpp.impl
Modifier and TypeMethodDescriptionprotected Packet
SaslAuthAbstract.createSaslErrorResponse
(XmppSaslException.SaslError error, String message, Packet packet) static Packet
C2SDeliveryErrorProcessor.makeDeliveryError
(Packet packet, Long stamp) Creates delivery-error packets to send to session manager to reprocess undelivered packetsstatic Packet
PresenceCapabilitiesManager.prepareCapsQuery
(JID to, JID from, String node) protected Packet
JabberIqPrivacy.prepareError
(Packet packet, XMPPResourceConnection session) static Packet
PresenceAbstract.sendPresence
(StanzaType t, JID from, JID to, Queue<Packet> results, Element pres) Sends Presence stanza from provided parameters as well as returns created resultPacket
object.Modifier and TypeMethodDescriptionFlexibleOfflineMessageRetrieval.restorePacketForOffLineUser
(List<String> db_ids, XMPPResourceConnection conn, MsgRepositoryIfc repo) OfflineMessages.restorePacketForOffLineUser
(XMPPResourceConnection conn, OfflineMsgRepositoryIfc repo) Method restores all messages from repository for the JID of the current session.Modifier and TypeMethodDescriptionvoid
PresenceSubscription.PresenceSubscriptionVHostItemExtension.addCommandFields
(String prefix, Packet packet, boolean forDefault) protected boolean
JabberIqPrivacy.allowed
(Packet packet, JID connId, BareJID userJid, PrivacyList privacyList) protected boolean
JabberIqPrivacy.allowed
(Packet packet, XMPPResourceConnection session) protected boolean
JabberIqPrivacy.allowedByDefault
(Packet packet, JID connId, BareJID userJid) FlexibleOfflineMessageRetrieval.canHandle
(Packet packet, XMPPResourceConnection conn) JabberIqCommand.canHandle
(Packet packet, XMPPResourceConnection conn) JabberIqStats.canHandle
(Packet packet, XMPPResourceConnection conn) MIXProcessor.canHandle
(Packet packet, XMPPResourceConnection conn) int
void
protected Packet
SaslAuthAbstract.createSaslErrorResponse
(XmppSaslException.SaslError error, String message, Packet packet) protected void
JabberIqRegister.doGetRegistrationForm
(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRegister.doRemoveAccount
(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected static void
JabberIqRoster.dynamicGetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterget
request related to dynamic roster.protected static void
JabberIqRoster.dynamicSetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterset
request related to dynamic roster.static void
C2SDeliveryErrorProcessor.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, JID toIgnore) Filters packets created by processors to remove delivery-error payloadvoid
ClientStateIndication.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
DomainFilter.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
ErrorCounter.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
JabberIqPrivacy.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
Message.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
MessageAmp.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
MessageCarbons.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
MobileV1.filter
(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) void
MobileV2.filter
(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) void
MobileV3.filter
(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) protected static void
PresenceAbstract.forwardPresence
(Queue<Packet> results, Packet packet, JID from) Simply forwards packet to the destinationstatic Element
C2SDeliveryErrorProcessor.getDeliveryError
(Packet packet) Finds delivery-error element in packet and returns itprotected static long
LastActivityAbstract.getLastActivity
(XMPPResourceConnection session, Packet packet) void
MessageDeliveryLogic.handleDelivery
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PresenceSubscription.PresenceSubscriptionVHostItemExtension.initFromCommand
(String prefix, Packet packet) protected boolean
OfflineMessages.isAllowedForOfflineStorage
(Packet pac) Method determines whether packet sent to offline user should be stored in offline storage or notprotected boolean
OfflineMessages.isAllowedForOfflineStorageDefaults
(Packet pac) static boolean
C2SDeliveryErrorProcessor.isDeliveryError
(Packet packet) Checks if packet is delivery-error packetprotected boolean
AbstractAuthPreprocessor.isPacketAllowed
(Packet packet) protected boolean
OfflineMessages.loadOfflineMessages
(Packet packet, XMPPResourceConnection conn) Method determines whether offline messages should be loaded - the process should be run only once per user session and only for available/null presence with priority greater than 0.static Packet
C2SDeliveryErrorProcessor.makeDeliveryError
(Packet packet, Long stamp) Creates delivery-error packets to send to session manager to reprocess undelivered packetsvoid
OfflineMessages.Notifier.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) protected void
OfflineMessages.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) void
OfflineMessages.PubSubPublisherNotifier.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) void
VCardTemp.pepToVCardTemp_onDataRetrieved
(Packet packet, XMPPResourceConnection session) void
MessageAmp.postProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
OfflineMessages.postProcess
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> queue, Map<String, Object> settings) Performs processing ofpacket
for which there was no processor.protected Packet
JabberIqPrivacy.prepareError
(Packet packet, XMPPResourceConnection session) MessageCarbons.prepareSkipForkingToList
(Packet packet, XMPPResourceConnection session, Map<JID, Boolean> resources) boolean
AbstractAuthPreprocessor.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
AddressingSanitizer.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static boolean
C2SDeliveryErrorProcessor.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings, MessageDeliveryLogic messageProcessor) Filters packets before they are processed by processors to filter out delivery-error packets sent to bare jid if other connection is availableboolean
DomainFilter.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
InvisibleCommand.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
JabberIqIq.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
JabberIqPrivacy.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket
.boolean
Message.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
MessageAmp.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
StartTLS.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
MessageDeliveryLogic.preProcessFilter
(Packet packet, XMPPResourceConnection session) void
BindResource.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
BlockingCommand.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
CAPS.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ClientStateIndication.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
ErrorCounter.process
(Packet packet, XMPPResourceConnection session) void
InvisibleCommand.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqAuth.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqCommand.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqIq.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqPrivacy.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqPrivate.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqRegister.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
TODO: Implement registration form configurable and loading all the fields from the registration form TODO: rewrite the plugin using the XMPPProcessorAbstract APIvoid
JabberIqRoster.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
Performs processing of IQ packets with jabber:iq:roster xmlns with the regard whether it's roster set or get request or possibly dynamic-roster is involved.void
JabberIqStats.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
Jingle.process
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository nonAuthUserRepo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivityMarker.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
Message.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageAll.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageAmp.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageCarbons.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageForwarding.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MIXProcessor.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MobileV1.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MobileV2.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MobileV3.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MotdProcessor.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
OfflineMessages.process
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
OfflineMessages
processor is triggered by<presence>
stanza.void
PresenceOffline.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PresenceState.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
Performs processing of presence packets and calls different methods for particularRosterAbstract.PresenceType
void
PresenceSubscription.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
Performs processing of presence packets and calls different methods for particularRosterAbstract.PresenceType
void
SaslAuth.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SaslAuth2.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionBind.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SimpleForwarder.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
StartTLS.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
StartZLib.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static void
PresenceCapabilitiesManager.processCapsQueryResponse
(Packet packet) protected void
PresenceState.processError
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Process presence stanza of type Error.void
EntityTime.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processFromUserPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processFromUserPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
BlockingCommand.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
EntityTime.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
FlexibleOfflineMessageRetrieval.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PepPlugin.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
RemoteRosterManagement.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
UrnXmppPing.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
JabberIqPrivacy.processGetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRoster.processGetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterget
request.protected void
PresenceState.processInInitial
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Method is responsible for processing incoming initial presence (i.e.protected void
PresenceState.processInProbe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Method is responsible for processing incoming presence probe (i.e.protected void
PresenceSubscription.processInSubscribe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming subscription request (i.e.protected void
PresenceSubscription.processInSubscribed
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming subscribed presence (i.e.protected void
PresenceSubscription.processInUnsubscribe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming unsubscribe presence (i.e.protected void
PresenceSubscription.processInUnsubscribed
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming unsubscribed presence (i.e.void
OfflineMessages.processIq
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results) void
EntityTime.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PepPlugin.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
UrnXmppPing.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
PresenceState.processOutInitial
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType type) Method is responsible for processing outgoing initial presence (i.e.protected void
PresenceSubscription.processOutSubscribe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing outgoing subscribe and unsubscribe presence (i.e.protected void
PresenceSubscription.processOutSubscribed
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing outgoing subscribed and unsubscribed presence (i.e.static String[]
PresenceCapabilitiesManager.processPresence
(JID compJid, Packet p, Queue<Packet> results) void
BlockingCommand.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
EntityTime.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
FlexibleOfflineMessageRetrieval.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PepPlugin.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
RemoteRosterManagement.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
UrnXmppPing.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
SaslAuthAbstract.processSessionAlreadyAuthorized
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqPrivacy.processSetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRoster.processSetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterset
request.protected void
SaslAuth.processSuccess
(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected void
SaslAuth2.processSuccess
(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected abstract void
SaslAuthAbstract.processSuccess
(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) void
EntityTime.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
RemoteRosterManagement.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
AddressingSanitizer.sanitizePacket
(Packet packet, JID stanzaFrom) OfflineMessages.savePacketForOffLineUser
(Packet packet, OfflineMsgRepositoryIfc repo, NonAuthUserRepository userRepo) Method stores messages to offline repository with the following rules applied, i.e.protected boolean
MobileV1.shouldBeQueued
(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Queue<Packet> queue) protected boolean
MobileV2.shouldBeQueued
(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Map<JID, Packet> queue) protected boolean
MessageCarbons.shouldSendCarbons
(Packet packet, XMPPResourceConnection session) static void
PresenceAbstract.updatePresenceChange
(Packet presence, XMPPResourceConnection session, Queue<Packet> results) updatePresenceChange
method is used to broadcast to all active resources presence stanza received from other users, like incoming availability presence, subscription presence and so on...Modifier and TypeMethodDescriptionvoid
ClientStateIndication.Logic.activate
(XMPPResourceConnection session, Queue<Packet> results) void
MobileV1.activate
(XMPPResourceConnection session, Queue<Packet> results) void
MobileV2.activate
(XMPPResourceConnection session, Queue<Packet> results) protected static void
PresenceState.broadcastDirectPresences
(StanzaType t, XMPPResourceConnection session, Queue<Packet> results, Element pres) broadcastDirectPresences
broadcast a direct Presence from providedpres
Element
object to the collection of JIDs stored in temporary session data under keyDIRECT_PRESENCE
.static void
PresenceState.broadcastOffline
(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract roster_util) sendPresenceBroadcast
method broadcasts given presence to all buddies from roster and to all users to which direct presence was sent.void
PresenceAbstract.broadcastProbe
(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) sendPresenceBroadcast
method broadcasts given presence to all buddies from roster and to all users to which direct presence was sent.protected void
PresenceState.buddyOnline
(XMPPResourceConnection session, JID buddy, Queue<Packet> results, boolean online) Method sends back presence to contact while it becomes online (i.e.void
ClientStateIndication.Logic.deactivate
(XMPPResourceConnection session, Queue<Packet> results) void
MobileV1.deactivate
(XMPPResourceConnection session, Queue<Packet> results) void
MobileV2.deactivate
(XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRegister.doGetRegistrationForm
(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRegister.doRemoveAccount
(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected static void
JabberIqRoster.dynamicGetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterget
request related to dynamic roster.protected static void
JabberIqRoster.dynamicSetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterset
request related to dynamic roster.default Element
PresenceState.ExtendedPresenceProcessorIfc.extend
(Element presence, XMPPResourceConnection session, Queue<Packet> results) PresenceState.ExtendedPresenceProcessorIfc.extend
(XMPPResourceConnection session, Queue<Packet> results) VCardTemp.extend
(Element presence, XMPPResourceConnection session, Queue<Packet> results) VCardTemp.extend
(XMPPResourceConnection session, Queue<Packet> results) static void
C2SDeliveryErrorProcessor.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, JID toIgnore) Filters packets created by processors to remove delivery-error payloadvoid
ClientStateIndication.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
DomainFilter.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
ErrorCounter.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
JabberIqPrivacy.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
Message.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
MessageAmp.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
MessageCarbons.filter
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) void
MobileV1.filter
(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) void
MobileV2.filter
(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) void
MobileV3.filter
(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) protected void
MobileV1.flushQueue
(XMPPResourceConnection session, Queue<Packet> results) protected void
MobileV2.flushQueue
(XMPPResourceConnection session, Queue<Packet> results) protected static void
PresenceAbstract.forwardPresence
(Queue<Packet> results, Packet packet, JID from) Simply forwards packet to the destinationvoid
MessageDeliveryLogic.handleDelivery
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static void
PresenceCapabilitiesManager.handlePresence
(JID owner, JID from, String[] capsNodes, Queue<Packet> results) void
PresenceCapabilitiesManager.PresenceCapabilitiesListener.handlePresence
(JID owner, JID sender, String[] capsNodes, Queue<Packet> results) void
OfflineMessages.Notifier.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) protected void
OfflineMessages.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) void
OfflineMessages.PubSubPublisherNotifier.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) default void
OfflineMessages.Notifier.notifyOfflineMessagesRetrieved
(XMPPResourceConnection session, Queue<Packet> results) protected void
OfflineMessages.notifyOfflineMessagesRetrieved
(XMPPResourceConnection conn, Queue<Packet> queue) void
VCardTemp.pepToVCardTemp_onPublication
(BareJID userJid, XMPPResourceConnection session, String itemId, String mimeType, Supplier<JID> pubsubComponentJidSupplier, Consumer<Packet> writer) void
MessageAmp.postProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
OfflineMessages.postProcess
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> queue, Map<String, Object> settings) Performs processing ofpacket
for which there was no processor.static void
PresenceCapabilitiesManager.prepareCapsQueries
(JID compJid, JID to, String[] caps_nodes, Queue<Packet> results) boolean
AbstractAuthPreprocessor.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
AddressingSanitizer.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static boolean
C2SDeliveryErrorProcessor.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings, MessageDeliveryLogic messageProcessor) Filters packets before they are processed by processors to filter out delivery-error packets sent to bare jid if other connection is availableboolean
DomainFilter.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
InvisibleCommand.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
JabberIqIq.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
JabberIqPrivacy.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket
.boolean
Message.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
MessageAmp.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) boolean
StartTLS.preProcess
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
BindResource.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
BlockingCommand.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
CAPS.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ClientStateIndication.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
InvisibleCommand.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqAuth.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqCommand.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqIq.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqPrivacy.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqPrivate.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqRegister.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
TODO: Implement registration form configurable and loading all the fields from the registration form TODO: rewrite the plugin using the XMPPProcessorAbstract APIvoid
JabberIqRoster.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
Performs processing of IQ packets with jabber:iq:roster xmlns with the regard whether it's roster set or get request or possibly dynamic-roster is involved.void
JabberIqStats.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
Jingle.process
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository nonAuthUserRepo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivityMarker.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
Message.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageAll.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageAmp.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageCarbons.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MessageForwarding.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MIXProcessor.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MobileV1.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MobileV2.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MobileV3.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
MotdProcessor.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
OfflineMessages.process
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
OfflineMessages
processor is triggered by<presence>
stanza.void
PresenceOffline.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PresenceState.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
Performs processing of presence packets and calls different methods for particularRosterAbstract.PresenceType
void
PresenceSubscription.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
Performs processing of presence packets and calls different methods for particularRosterAbstract.PresenceType
void
SaslAuth.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SaslAuth2.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SessionBind.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
SimpleForwarder.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
StartTLS.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
StartZLib.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
PresenceState.processError
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Process presence stanza of type Error.void
EntityTime.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processFromUserOutPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processFromUserPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processFromUserPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
BlockingCommand.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
EntityTime.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
FlexibleOfflineMessageRetrieval.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PepPlugin.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
RemoteRosterManagement.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
UrnXmppPing.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processFromUserToServerPacket
(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
JabberIqPrivacy.processGetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRoster.processGetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterget
request.protected void
PresenceState.processInInitial
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Method is responsible for processing incoming initial presence (i.e.protected void
PresenceState.processInProbe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Method is responsible for processing incoming presence probe (i.e.protected void
PresenceSubscription.processInSubscribe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming subscription request (i.e.protected void
PresenceSubscription.processInSubscribed
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming subscribed presence (i.e.protected void
PresenceSubscription.processInUnsubscribe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming unsubscribe presence (i.e.protected void
PresenceSubscription.processInUnsubscribed
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing incoming unsubscribed presence (i.e.void
OfflineMessages.processIq
(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results) void
EntityTime.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PepPlugin.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
UrnXmppPing.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processNullSessionPacket
(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
PresenceState.processOutInitial
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType type) Method is responsible for processing outgoing initial presence (i.e.protected void
PresenceSubscription.processOutSubscribe
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing outgoing subscribe and unsubscribe presence (i.e.protected void
PresenceSubscription.processOutSubscribed
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType pres_type) Method is responsible for processing outgoing subscribed and unsubscribed presence (i.e.static String[]
PresenceCapabilitiesManager.processPresence
(JID compJid, Packet p, Queue<Packet> results) void
BlockingCommand.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
EntityTime.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
FlexibleOfflineMessageRetrieval.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
JabberIqVersion.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PepPlugin.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
RemoteRosterManagement.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
ServiceDiscovery.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
UrnXmppPing.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processServerSessionPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected void
SaslAuthAbstract.processSessionAlreadyAuthorized
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqPrivacy.processSetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected void
JabberIqRoster.processSetRequest
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rosterset
request.protected void
SaslAuth.processSuccess
(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected void
SaslAuth2.processSuccess
(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected abstract void
SaslAuthAbstract.processSuccess
(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) void
EntityTime.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
LastActivity.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
RemoteRosterManagement.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCard4.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
VCardTemp.processToUserPacket
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) void
PresenceState.rebroadcastPresence
(XMPPResourceConnection session, Queue<Packet> results) void
PresenceState.resendPendingInRequests
(XMPPResourceConnection session, Queue<Packet> results) Sends out all pending subscription request during user log-in.static void
PresenceAbstract.sendPresence
(StanzaType t, BareJID from, BareJID to, Queue<Packet> results, Element pres) Sends Presence stanza from provided parameters without returning created resultPacket
object.static Packet
PresenceAbstract.sendPresence
(StanzaType t, JID from, JID to, Queue<Packet> results, Element pres) Sends Presence stanza from provided parameters as well as returns created resultPacket
object.static void
PresenceState.sendPresenceBroadcast
(StanzaType t, XMPPResourceConnection session, EnumSet<RosterAbstract.SubscriptionType> subscrs, Queue<Packet> results, Element pres, Map<String, Object> settings, RosterAbstract roster_util) sendPresenceBroadcast
method broadcasts given presence to all buddies from roster and to all users to which direct presence was sent.protected void
PresenceState.sendRosterOfflinePresence
(XMPPResourceConnection session, Queue<Packet> results) Method sends server generated presence unavailable for all buddies from the roster with a custom status message.void
MIXProcessor.sendToChannel
(BareJID userJid, String resource, BareJID channel, String requestStanzaId, Element joinEl, Consumer<Packet> writer) protected void
MIXProcessor.sendToChannel
(BareJID userJID, BareJID channel, String id, Element actionEl, Consumer<Packet> writer) protected void
MIXProcessor.sendToUser
(BareJID userJID, String resource, JID connectionJID, StanzaType stanzaType, String id, Element actionEl, Element errorEl, Consumer<Packet> writer) protected boolean
MobileV1.shouldBeQueued
(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Queue<Packet> queue) protected boolean
MobileV2.shouldBeQueued
(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Map<JID, Packet> queue) void
LastActivityMarker.stopped
(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) void
PresenceOffline.stopped
(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) void
PresenceState.stopped
(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) static void
RemoteRosterManagement.updateBuddyChange
(XMPPResourceConnection session, Element item, Element update, Queue<Packet> results) protected static void
PresenceState.updateOfflineChange
(XMPPResourceConnection session, Queue<Packet> results) updateOfflineChange
method broadcast off-line presence to all other user active resources.static void
PresenceAbstract.updatePresenceChange
(Packet presence, XMPPResourceConnection session, Queue<Packet> results) updatePresenceChange
method is used to broadcast to all active resources presence stanza received from other users, like incoming availability presence, subscription presence and so on...static void
PresenceAbstract.updateUserResources
(Element presence, XMPPResourceConnection session, Queue<Packet> results, boolean initial) updateUserResources
method is used to broadcast to all other resources presence stanza from one user resource. -
Uses of Packet in tigase.xmpp.impl.push
Modifier and TypeMethodDescriptionprotected boolean
IgnoreFromUnknownFilter.isInRoster
(Packet packet, XMPPResourceConnection session) protected boolean
GroupchatFilter.isMentioned
(Packet packet, String nick) protected boolean
AbstractPushNotifications.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) boolean
GroupchatFilter.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) boolean
IgnoreFromUnknownFilter.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) boolean
JinglePushNotificationsExtension.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) boolean
MutedFilter.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) protected boolean
PushNotifications.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) boolean
PushNotificationsFilter.isSendingNotificationAllowed
(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) void
PushNotifications.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> map) protected Element
AbstractPushNotifications.prepareNotificationPayload
(Element pushServiceSettings, Packet packet, long msgCount) void
EncryptedPushNotificationExtension.prepareNotificationPayload
(Element pushServiceSettings, Packet packet, long msgCount, Element notification) void
PriorityExtension.prepareNotificationPayload
(Element pushServiceSettings, Packet packet, long msgCount, Element notification) protected Element
PushNotifications.prepareNotificationPayload
(Element pushServiceSettings, Packet packet, long msgCount) default void
PushNotificationsExtension.prepareNotificationPayload
(Element pushServiceSettings, Packet packet, long msgCount, Element notification) void
AbstractPushNotifications.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) void
PushNotifications.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) protected void
AbstractPushNotifications.processMessage
(Packet packet, XMPPResourceConnection session, Consumer<Packet> results) protected void
PushNotifications.processMessage
(Packet packet, XMPPResourceConnection session, Consumer<Packet> consumer) protected void
AbstractPushNotifications.sendPushNotification
(BareJID userJid, Collection<Element> pushServices, XMPPResourceConnection session, Packet packet, Map<Enum, Long> notificationData) protected void
AbstractPushNotifications.sendPushNotification
(XMPPResourceConnection session, Packet packet) boolean
AwayPushNotificationsExtension.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) boolean
EncryptedPushNotificationExtension.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) boolean
GroupchatPushNotificationsExtension.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) boolean
JinglePushNotificationsExtension.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) boolean
PriorityExtension.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) protected boolean
PushNotifications.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) boolean
PushNotificationsExtension.shouldSendNotification
(Packet packet, BareJID userJid, XMPPResourceConnection session) Modifier and TypeMethodDescriptionvoid
PushNotifications.notifyNewOfflineMessage
(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> map) void
PushNotifications.notifyOfflineMessagesRetrieved
(XMPPResourceConnection session, Queue<Packet> results) void
AbstractPushNotifications.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) void
PushNotifications.process
(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) protected void
AbstractPushNotifications.processMessage
(Packet packet, XMPPResourceConnection session, Consumer<Packet> results) protected void
PushNotifications.processMessage
(Packet packet, XMPPResourceConnection session, Consumer<Packet> consumer) -
Uses of Packet in tigase.xmpp.impl.roster
Modifier and TypeMethodDescriptionRosterAbstract.addJidToRoster
(UserRepository repository, XMPPSession session, BareJID owner, RosterElement rosterElement) RosterAbstract.removeJidFromRoster
(UserRepository repository, XMPPSession session, BareJID owner, JID jid) Deprecated.Modifier and TypeMethodDescriptionRosterAbstract.getPresenceType
(XMPPResourceConnection session, Packet packet) Modifier and TypeMethodDescriptionvoid
RosterAbstract.updateBuddyChange
(XMPPResourceConnection session, Queue<Packet> results, Element item) -
Uses of Packet in tigase.xmpp.mam
Modifier and TypeMethodDescriptionMAM2ExtendedQueryParser.parseQuery
(Query query, Packet packet) MAMQueryParser.parseQuery
(Query query, Packet packet) QueryParser.parseQuery
(Q query, Packet packet) MAM2ExtendedQueryParser.prepareForm
(Element elem, String xmlns, Packet packet) MAMQueryParser.prepareForm
(Element elem, String xmlns, Packet packet) default Element
QueryParser.prepareForm
(Element elem, String xmlns, Packet packet) -
Uses of Packet in tigase.xmpp.mam.modules