Uses of Class
tigase.server.Packet
Packages that use 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
Methods in tigase.auth with parameters of type PacketModifier and TypeMethodDescriptionvoidBruteForceLockerBean.BruteForceLockerVHostExtension.addCommandFields(String prefix, Packet packet, boolean forDefault) voidBruteForceLockerBean.BruteForceLockerVHostExtension.initFromCommand(String prefix, Packet packet) -
Uses of Packet in tigase.cluster
Methods in tigase.cluster that return types with arguments of type PacketModifier and TypeMethodDescriptionClusterConnectionManager.processSocketData(XMPPIOService<Object> serv) Methods in tigase.cluster with parameters of type PacketModifier and TypeMethodDescriptionbooleanSessionManagerClustered.fastAddOutPacket(Packet packet) protected voidAmpComponentClustered.forwardPacket(Packet packet) SessionManagerClustered.getXMPPResourceConnection(Packet p) voidSessionManagerClustered.handleLocalPacket(Packet packet, XMPPResourceConnection conn) intClusterConnectionManager.hashCodeForPacket(Packet packet) voidClusterConnectionManager.processOutPacket(Packet packet) voidAmpComponentClustered.processPacket(Packet packet) voidClusterConnectionManager.processPacket(Packet packet) voidClusterController.processPacket(Packet packet, Queue<Packet> results) voidSessionManagerClustered.processPacket(Packet packet) This is the mainPacketprocessing method.voidSessionManagerClustered.processPacket(Packet packet, XMPPResourceConnection conn) voidVirtualComponent.processPacket(Packet packet, Queue<Packet> results) booleanClusterConnectionManager.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) ClusterConnectionSelector.selectConnection(Packet p, ClusterConnection conn) ClusterConnectionSelectorOld.selectConnection(Packet p, ClusterConnection conn) protected booleanClusterConnectionManager.writePacketToSocket(Packet p) Method parameters in tigase.cluster with type arguments of type PacketModifier and TypeMethodDescriptionvoidClusterController.processPacket(Packet packet, Queue<Packet> results) voidVirtualComponent.processPacket(Packet packet, Queue<Packet> results) -
Uses of Packet in tigase.cluster.api
Methods in tigase.cluster.api with parameters of type PacketModifier and TypeMethodDescriptionvoidClusterElement.addDataPacket(Packet packet) booleanSessionManagerClusteredIfc.fastAddOutPacket(Packet packet) SessionManagerClusteredIfc.getXMPPResourceConnection(Packet el_packet) intClusterConnectionHandler.hashCodeForPacket(Packet packet) Generates hashCode for particular packet used to spread processing between thread or connectionsvoidSessionManagerClusteredIfc.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 nodesConstructors in tigase.cluster.api with parameters of type Packet -
Uses of Packet in tigase.cluster.repo
Methods in tigase.cluster.repo with parameters of type PacketModifier and TypeMethodDescriptionvoidClusterRepoItem.addCommandFields(Packet packet) voidClusterRepoItem.initFromCommand(Packet packet) -
Uses of Packet in tigase.cluster.strategy
Methods in tigase.cluster.strategy with parameters of type PacketModifier 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) voidClusteringStrategyIfc.handleLocalPacket(Packet packet, XMPPResourceConnection conn) voidDefaultClusteringStrategy.handleLocalPacket(Packet packet, XMPPResourceConnection conn) voidDefaultClusteringStrategyAbstract.handleLocalPacket(Packet packet, XMPPResourceConnection conn) booleanDefaultClusteringStrategyAbstract.isIqResponseToNode(Packet packet) protected booleanDefaultClusteringStrategyAbstract.isSuitableForForward(Packet packet) protected booleanSMNonCachingAllNodes.isSuitableForForward(Packet packet) booleanClusteringStrategyIfc.processPacket(Packet packet, XMPPResourceConnection conn) booleanDefaultClusteringStrategyAbstract.processPacket(Packet packet, XMPPResourceConnection conn) booleanDefaultClusteringStrategyAbstract.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
Methods in tigase.component with parameters of type PacketModifier and TypeMethodDescriptionprotected voidAbstractComponent.addOutPacket(Packet packet, AsyncCallback asyncCallback) Deprecated.voidAbstractComponent.processPacket(Packet packet) Deprecated.voidAbstractKernelBasedComponent.processPacket(Packet packet) booleanComponenScriptCommandProcessor.processScriptCommand(Packet pc, Queue<Packet> results) voidvoidAbstractComponent.DefaultPacketWriter.write(Packet packet, AsyncCallback callback) voidvoidAbstractKernelBasedComponent.DefaultPacketWriter.write(Packet packet, AsyncCallback callback) voidWrites single Packet.voidPacketWriter.write(Packet packet, AsyncCallback callback) Method parameters in tigase.component with type arguments of type PacketModifier and TypeMethodDescriptionbooleanComponenScriptCommandProcessor.processScriptCommand(Packet pc, Queue<Packet> results) voidAbstractComponent.DefaultPacketWriter.write(Collection<Packet> elements) voidAbstractKernelBasedComponent.DefaultPacketWriter.write(Collection<Packet> elements) voidPacketWriter.write(Collection<Packet> packets) Writes collection of Packets. -
Uses of Packet in tigase.component.adhoc
Methods in tigase.component.adhoc that return PacketMethods in tigase.component.adhoc that return types with arguments of type PacketMethods in tigase.component.adhoc with parameters of type PacketModifier and TypeMethodDescriptionvoidvoidAdHocCommandManager.process(Packet packet, Element commandElement, String node, String action, String sessionId, AdHocCommand adHocCommand, Consumer<Packet> resultConsumer) Method parameters in tigase.component.adhoc with type arguments of type Packet -
Uses of Packet in tigase.component.modules
Methods in tigase.component.modules with parameters of type PacketModifier and TypeMethodDescriptiondefault booleanReturns true if Packet can be procesed by module.voidProcess incoming stanza.voidStanzaProcessor.processPacket(Packet packet) voidStanzaProcessor.sendException(Packet packet, ComponentException e) ConvertsComponentExceptionto XMPP error stanza and sends it to sender of packet.protected booleanStanzaProcessor.shouldSendException(Packet packet) protected voidprotected voidAbstractModule.write(Packet packet, AsyncCallback asyncCallback) -
Uses of Packet in tigase.component.modules.impl
Methods in tigase.component.modules.impl that return PacketModifier and TypeMethodDescriptionprotected PacketDiscoveryModule.prepareDiscoInfoReponse(Packet packet, JID jid, String node, JID senderJID) Deprecated.protected PacketDiscoveryModule.prepareDiscoInfoResponse(Packet packet, JID jid, String node, JID senderJID) Methods in tigase.component.modules.impl with parameters of type PacketModifier and TypeMethodDescriptionprotected PacketDiscoveryModule.prepareDiscoInfoReponse(Packet packet, JID jid, String node, JID senderJID) Deprecated.protected PacketDiscoveryModule.prepareDiscoInfoResponse(Packet packet, JID jid, String node, JID senderJID) voidvoidvoidvoidprotected voidDiscoveryModule.processAdHocCommandItems(Packet packet, JID jid, String node, JID senderJID) protected voidDiscoveryModule.processDiscoInfo(Packet packet, JID jid, String node, JID senderJID) protected voidDiscoveryModule.processDiscoItems(Packet packet, JID jid, String node, JID senderJID) protected voidAdHocCommandModule.processScriptAdHoc(Packet packet) booleanAdHocCommandModule.ScriptCommandProcessor.processScriptCommand(Packet pc, Queue<Packet> results) Method parameters in tigase.component.modules.impl with type arguments of type PacketModifier and TypeMethodDescriptionbooleanAdHocCommandModule.ScriptCommandProcessor.processScriptCommand(Packet pc, Queue<Packet> results) -
Uses of Packet in tigase.component.responses
Methods in tigase.component.responses with parameters of type PacketModifier and TypeMethodDescriptionResponseManager.getResponseHandler(Packet element) Returns handler for response of sent<iq/>stanza.voidCalled when received response has type error.voidCalled when received response has type result.ResponseManager.registerResponseHandler(Packet stanza, Long timeout, AsyncCallback callback) Register callback for response of sent<iq/>stanza.Constructors in tigase.component.responses with parameters of type Packet -
Uses of Packet in tigase.conf
Methods in tigase.conf with parameters of type PacketModifier and TypeMethodDescriptionvoidConfigItem.addCommandFields(Packet packet) voidConfigItem.initFromCommand(Packet packet) voidConfiguratorOld.processPacket(Packet packet, Queue<Packet> results) ConfiguratorOld.setPropertyValue(String key, String val, Packet result_pack, boolean admin) Method parameters in tigase.conf with type arguments of type PacketModifier and TypeMethodDescriptionvoidConfiguratorOld.processPacket(Packet packet, Queue<Packet> results) voidSetLoggingCommand.runCommand(Iq packet, Bindings binds, Queue<Packet> results) -
Uses of Packet in tigase.db.comp
Methods in tigase.db.comp with parameters of type PacketModifier and TypeMethodDescriptionvoidRepositoryItem.addCommandFields(Packet packet) The method is used for handling ad-hoc commands.voidRepositoryItemAbstract.addCommandFields(Packet packet) voidRepositoryItem.initFromCommand(Packet packet) The method used for handling ad-hoc commands.voidRepositoryItemAbstract.initFromCommand(Packet packet) -
Uses of Packet in tigase.disco
Methods in tigase.disco with parameters of type PacketModifier and TypeMethodDescriptionvoidXMPPServiceCollector.processPacket(Packet packet, Queue<Packet> results) Method parameters in tigase.disco with type arguments of type PacketModifier and TypeMethodDescriptionvoidXMPPServiceCollector.processPacket(Packet packet, Queue<Packet> results) -
Uses of Packet in tigase.eventbus.component
Methods in tigase.eventbus.component with parameters of type PacketModifier and TypeMethodDescriptionvoidvoidvoidvoidprotected ElementSubscribeModule.processClusterSubscription(Packet packet) protected voidEventbusDiscoveryModule.processDiscoInfo(Packet packet, JID jid, String node, JID senderJID) protected voidEventbusDiscoveryModule.processDiscoItems(Packet packet, JID jid, String node, JID senderJID) protected ElementSubscribeModule.processNonClusterSubscription(Packet packet) voidEventBusComponent.processPacket(Packet packet) -
Uses of Packet in tigase.io
Modifier and TypeMethodDescriptionvoidSSLContextContainer.HardenedModeVHostItemExtension.addCommandFields(String prefix, Packet packet, boolean forDefault) voidSSLContextContainer.HardenedModeVHostItemExtension.initFromCommand(String prefix, Packet packet) -
Uses of Packet in tigase.io.repo
Methods in tigase.io.repo with parameters of type PacketModifier and TypeMethodDescriptionvoidCertificateItem.addCommandFields(Packet packet) voidCertificateItem.initFromCommand(Packet packet) -
Uses of Packet in tigase.monitor.modules
Methods in tigase.monitor.modules with parameters of type PacketModifier and TypeMethodDescriptionvoidprotected voidDiscoveryMonitorModule.processAdHocCommandItems(Packet packet, JID jid, String node, JID senderJID) protected voidDiscoveryMonitorModule.processDiscoInfo(Packet packet, JID jid, String node, JID senderJID) protected voidDiscoveryMonitorModule.processDiscoItems(Packet packet, JID jid, String node, JID senderJID) -
Uses of Packet in tigase.server
Subclasses of Packet in tigase.serverModifier and TypeClassDescriptionclassCreated: Dec 31, 2009 8:43:21 PMclassCreated: Dec 31, 2009 8:38:38 PMclassCreated: Dec 31, 2009 8:42:05 PMMethods in tigase.server that return PacketModifier and TypeMethodDescriptionIq.commandResult(Command.DataType cmd_type) static PacketIq.commandResultForm(Iq packet) static PacketIq.commandResultResult(Iq packet) Packet.copyElementOnly()copyElementOnlymethod 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 thePacketwith its stanza as stanza error used for reporting errors.This is the actual packet filtering method.static PacketMessage.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 thePacketwith its stanza as stanzaresultused for reporting IQ stanza results.Method returns a modified copy of thePacketwith its stanza as stanzaresultused for reporting IQ stanza results.static PacketPacket.packetInstance(String el_name, String from, String to, StanzaType type) The method creates XML stanza from given parameters and returnsPacketinstance for this XML stanza.static PacketPacket.packetInstance(Element elem) The method returnsPacketinstance.static PacketPacket.packetInstance(Element elem, JID stanzaFrom, JID stanzaTo) The method returnsPacketinstance.Packet.packRouted()Returns a newPacketinstance with stanza routed which means an original stanza has been enclosed inside arouteXML element which contains additional information taken fromPacketpacket instance internal attributes.Packet.swapFromTo()Creates a newPacketinstance with swapped packet source and destination addresses.Packet.swapFromTo(Element el, JID stanzaFrom, JID stanzaTo) The method creates a new instance of thePacketclass 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 newPacketinstance with a stanza copy with swapped source and destination addresses.Packet.swapStanzaFromTo(StanzaType type) The method creates a newPacketinstance 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 fromroutestanza.Methods in tigase.server that return types with arguments of type PacketMethods in tigase.server with parameters of type PacketModifier and TypeMethodDescriptionstatic voidCommand.addAction(Packet packet, Command.Action action) static voidCommand.addCheckBoxField(Packet packet, String f_name, boolean f_value) voidBasicComponent.ServerInfoVHostItemExtension.addCommandFields(String prefix, Packet packet, boolean forDefault) static voidCommand.addFieldMultiValue(Packet packet, String f_name, Throwable ex) static voidCommand.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 voidstatic voidCommand.addFieldValue(Packet packet, String f_name, String f_value) Simple method for adding a new field to the command data form.static voidCommand.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 voidCommand.addFieldValue(Packet packet, String f_name, String f_value, String type) static voidstatic voidCommand.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 voidCommand.addFieldValue(Packet packet, String f_name, String f_value, String label, String[] labels, String[] options, String type) static voidCommand.addHiddenField(Packet packet, String f_name, String f_value) static voidCommand.addInstructions(Packet packet, String instructions) static voidprotected booleanAbstractMessageReceiver.addOutPacket(Packet packet) protected booleanAbstractMessageReceiver.addOutPacketNB(Packet packet) Non blocking version ofaddOutPacket.booleanAbstractMessageReceiver.addOutPacketWithTimeout(Packet packet, Duration timeout, PacketWriterWithTimeout.Handler handler) booleanAbstractMessageReceiver.addOutPacketWithTimeout(Packet packet, ReceiverTimeoutHandler handler, long delay, TimeUnit unit) booleanPacketWriterWithTimeout.addOutPacketWithTimeout(Packet packet, Duration timeout, PacketWriterWithTimeout.Handler handler) booleanMethod adds aPacketobject to the internal input queue.booleanbooleanAbstractMessageReceiver.addPacketNB(Packet packet) This is a variant ofaddPacket(Packet)method which addsPacketto in the internal input queue without blocking.booleanMessageReceiver.addPacketNB(Packet packet) static voidCommand.addTextField(Packet packet, String f_name, String f_value) static voidThis is the actual packet filtering method.static Command.Actionstatic booleanCommand.getCheckBoxFieldValue(Packet packet, String f_name) static Elementstatic StringCommand.getFieldKeyStartingWith(Packet packet, String f_name) static StringCommand.getFieldValue(Packet packet, String f_name) static StringCommand.getFieldValue(Packet packet, String f_name, boolean debug) static String[]Command.getFieldValues(Packet packet, String f_name) protected StringConnectionManager.getServiceId(Packet packet) protected IOConnectionManager.getXMPPIOService(Packet p) voidintAbstractMessageReceiver.hashCodeForPacket(Packet packet) This method decides how incoming packets are distributed among processing threads.intConnectionManager.hashCodeForPacket(Packet packet) intMessageRouter.hashCodeForPacket(Packet packet) voidBasicComponent.ServerInfoVHostItemExtension.initFromCommand(String prefix, Packet packet) booleanStanzaSourceChecker.isPacketFromConnectionManager(Packet packet) voidAbstractMessageReceiver.processOutPacket(Packet packet) By default this method just copies the given packet between queue.abstract voidAbstractMessageReceiver.processPacket(Packet packet) This is the mainPacketprocessing method.final voidAbstractMessageReceiver.processPacket(Packet packet, Queue<Packet> results) voidBasicComponent.processPacket(Packet packet, Queue<Packet> results) voidConnectionManager.processPacket(Packet packet) voidMessageRouter.processPacket(Packet packet) voidServerComponent.processPacket(Packet packet, Queue<Packet> results) processPacketis a blocking processing method implemented by all components.voidMessageRouter.processPacketMR(Packet packet, Queue<Packet> results) booleanBasicComponent.processScriptCommand(Packet pc, Queue<Packet> results) abstract booleanConnectionManager.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) Processes undelivered packetsstatic booleanCommand.removeFieldValue(Packet packet, String f_name) voidReceiverTimeoutHandler.responseReceived(Packet data, Packet response) static voidstatic voidstatic voidCommand.setStatus(Packet packet, Command.Status status) voidReceiverTimeoutHandler.timeOutExpired(Packet data) booleanConnectionManager.writePacketToSocket(IO ios, Packet p) protected booleanConnectionManager.writePacketToSocket(Packet p) protected booleanConnectionManager.writePacketToSocket(Packet p, String serviceId) Method parameters in tigase.server with type arguments of type PacketModifier and TypeMethodDescriptionprotected booleanAbstractMessageReceiver.addOutPackets(Queue<Packet> packets) booleanAbstractMessageReceiver.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.booleanMessageReceiver.addPackets(Queue<Packet> packets) final voidAbstractMessageReceiver.processPacket(Packet packet, Queue<Packet> results) voidBasicComponent.processPacket(Packet packet, Queue<Packet> results) voidServerComponent.processPacket(Packet packet, Queue<Packet> results) processPacketis a blocking processing method implemented by all components.voidMessageRouter.processPacketMR(Packet packet, Queue<Packet> results) booleanBasicComponent.processScriptCommand(Packet pc, Queue<Packet> results) voidConnectionManager.writePacketsToSocket(IO serv, Queue<Packet> packets) Constructors in tigase.server with parameters of type Packet -
Uses of Packet in tigase.server.amp
Methods in tigase.server.amp that return PacketModifier and TypeMethodDescriptionprotected PacketActionAbstract.prepareAmpPacket(Packet packet, Element rule) Methods in tigase.server.amp with parameters of type PacketModifier and TypeMethodDescriptionbooleanActionResultsHandlerIfc.addOutPacket(Packet packet) booleanAmpComponent.addOutPacket(Packet packet) booleanbooleanprotected PacketActionAbstract.prepareAmpPacket(Packet packet, Element rule) voidAmpComponent.processPacket(Packet packet) protected voidActionAbstract.removeTigasePayload(Packet packet) Method parameters in tigase.server.amp with type arguments of type PacketModifier and TypeMethodDescriptionbooleanActionResultsHandlerIfc.addOutPackets(Queue<Packet> packets) booleanAmpComponent.addOutPackets(Queue<Packet> packets) -
Uses of Packet in tigase.server.amp.action
Methods in tigase.server.amp.action with parameters of type PacketModifier and TypeMethodDescriptionbooleanbooleanbooleanbooleanbooleanbooleanbooleanBroadcast.preprocess(Packet packet) -
Uses of Packet in tigase.server.amp.cond
Methods in tigase.server.amp.cond with parameters of type Packet -
Uses of Packet in tigase.server.bosh
Methods in tigase.server.bosh that return types with arguments of type PacketModifier and TypeMethodDescriptionBoshConnectionManager.processSocketData(XMPPIOService<Object> srv) Methods in tigase.server.bosh with parameters of type PacketModifier and TypeMethodDescriptionbooleanBoshConnectionManager.addOutStreamClosed(Packet packet, BoshSession bs, boolean withTimeout) booleanBoshSessionTaskHandler.addOutStreamClosed(Packet packet, BoshSession bs, boolean withTimeout) booleanBoshConnectionManager.addOutStreamOpen(Packet packet, BoshSession bs) booleanBoshSessionTaskHandler.addOutStreamOpen(Packet packet, BoshSession bs) protected JIDBoshConnectionManager.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) voidBoshSession.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 voidBoshSession.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 voidBoshConnectionManager.processCommand(Packet packet) voidBoshConnectionManager.processPacket(Packet packet) voidBoshSession.processPacket(Packet packet, Queue<Packet> out_results) voidBoshSession.processSocketPacket(Packet packet, BoshIOService service, Queue<Packet> out_results) booleanBoshSessionTaskHandler.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) voidBoshIOService.sendErrorAndStop(Authorization errorCode, StreamError streamError, Packet packet, String errorMsg) protected booleanBoshConnectionManager.writePacketToSocket(Packet packet) Method parameters in tigase.server.bosh with type arguments of type PacketModifier and TypeMethodDescriptionprotected voidBoshConnectionManager.addOutPackets(Queue<Packet> out_results, BoshSession bs) Method adds packets to the output queue stamping it with the appropriateBoshSessiondatavoidBoshSession.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 voidBoshSession.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) voidBoshSession.processPacket(Packet packet, Queue<Packet> out_results) voidBoshSession.processSocketPacket(Packet packet, BoshIOService service, Queue<Packet> out_results) boolean -
Uses of Packet in tigase.server.ext
Methods in tigase.server.ext that return types with arguments of type PacketMethods in tigase.server.ext with parameters of type PacketModifier and TypeMethodDescriptionvoidCompRepoItem.addCommandFields(Packet packet) voidComponentProtocol.authenticationFailed(ComponentIOService serv, Packet packet) voidComponentProtocolHandler.authenticationFailed(ComponentIOService serv, Packet packet) protected ComponentIOServiceComponentProtocol.getXMPPIOService(Packet p) voidCompRepoItem.initFromCommand(Packet packet) booleanExtProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanComponentProtocol.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) voidExtProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanComponentProtocol.writePacketToSocket(ComponentIOService ios, Packet p) Method parameters in tigase.server.ext with type arguments of type PacketModifier and TypeMethodDescriptionbooleanExtProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidExtProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) -
Uses of Packet in tigase.server.ext.handlers
Methods in tigase.server.ext.handlers with parameters of type PacketModifier and TypeMethodDescriptionbooleanBindProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanHandshakeProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanSASLProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanStartTLSProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanStreamFeaturesProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidBindProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidHandshakeProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidSASLProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidStartTLSProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidStreamFeaturesProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) Method parameters in tigase.server.ext.handlers with type arguments of type PacketModifier and TypeMethodDescriptionbooleanBindProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanHandshakeProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanSASLProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanStartTLSProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) booleanStreamFeaturesProcessor.process(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidBindProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidHandshakeProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidSASLProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidStartTLSProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) voidStreamFeaturesProcessor.startProcessing(Packet p, ComponentIOService serv, ComponentProtocolHandler handler, Queue<Packet> results) -
Uses of Packet in tigase.server.ext.lb
Methods in tigase.server.ext.lb with parameters of type PacketModifier 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
Methods in tigase.server.extdisco with parameters of type PacketModifier and TypeMethodDescriptionvoidExtServiceDiscoItem.addCommandFields(Packet packet) voidExtServiceDiscoItem.initFromCommand(Packet packet) voidvoidExternalServiceDiscoveryProcessor.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Method parameters in tigase.server.extdisco with type arguments of type PacketModifier and TypeMethodDescriptionvoidExternalServiceDiscoveryProcessor.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) -
Uses of Packet in tigase.server.filters
Methods in tigase.server.filters that return PacketMethods in tigase.server.filters with parameters of type Packet -
Uses of Packet in tigase.server.monitor
Methods in tigase.server.monitor with parameters of type PacketMethod parameters in tigase.server.monitor with type arguments of type Packet -
Uses of Packet in tigase.server.rtbl
Methods in tigase.server.rtbl with parameters of type PacketModifier and TypeMethodDescriptionRTBLIqModule.ResultEvent.Result.fromPacket(Packet packet) voidvoid -
Uses of Packet in tigase.server.script
Method parameters in tigase.server.script with type arguments of type PacketModifier and TypeMethodDescriptionvoidAddScriptCommand.runCommand(Iq packet, Bindings binds, Queue<Packet> results) voidCommandIfc.runCommand(Iq packet, Bindings binds, Queue<Packet> results) voidRemoveScriptCommand.runCommand(Iq packet, Bindings binds, Queue<Packet> results) voidScript.runCommand(Iq packet, Bindings binds, Queue<Packet> results) -
Uses of Packet in tigase.server.test
Methods in tigase.server.test with parameters of type PacketModifier and TypeMethodDescriptionintTestComponent.hashCodeForPacket(Packet packet) voidvoidvoidEchoComponent.processPacket(Packet packet) -
Uses of Packet in tigase.server.websocket
Methods in tigase.server.websocket with parameters of type PacketModifier and TypeMethodDescriptionprotected voidWebSocketXMPPIOService.addReceivedPacket(Packet packet) -
Uses of Packet in tigase.server.xmppclient
Methods in tigase.server.xmppclient that return PacketModifier and TypeMethodDescriptionStreamManagementIOProcessor.OutQueue.Entry.getPacketWithStamp()Methods in tigase.server.xmppclient that return types with arguments of type PacketModifier and TypeMethodDescriptionClientConnectionManager.processSocketData(XMPPIOService<Object> serv) Methods in tigase.server.xmppclient with parameters of type PacketModifier and TypeMethodDescriptionvoidClientTrustManagerFactory.ClientTrustVHostItemExtension.addCommandFields(String prefix, Packet packet, boolean forDefault) voidSeeOtherHost.SeeOtherHostVHostItemExtension.addCommandFields(String prefix, Packet packet, boolean forDefault) protected voidC2SIOService.addReceivedPacket(Packet packet) booleanDeprecated.booleanDeprecated.booleanStreamManagementIOProcessor.OutQueue.append(Packet packet, int maxQueueSize, int timeoutInSec, int burstPeriodInSec, int burstRatio) Append packet to waiting for ack queueprotected JIDClientConnectionManager.changeDataReceiver(Packet packet, JID newAddress, String command_sessionId, XMPPIOService<Object> serv) protected booleanRegistrationThrottling.checkLimits(XMPPIOService service, Packet packet) static StreamManagementCommandStreamManagementCommand.fromPacket(Packet packet) intClientConnectionManager.hashCodeForPacket(Packet packet) voidClientTrustManagerFactory.ClientTrustVHostItemExtension.initFromCommand(String prefix, Packet packet) voidSeeOtherHost.SeeOtherHostVHostItemExtension.initFromCommand(String prefix, Packet packet) protected booleanprotected voidClientConnectionManager.processCommand(Packet packet) voidRegistrationThrottlingProcessor.processCommand(XMPPIOService service, Packet packet) voidStreamErrorCounterIOProcessor.processCommand(XMPPIOService service, Packet packet) voidStreamManagementIOProcessor.processCommand(XMPPIOService service, Packet pc) voidXMPPIOProcessor.processCommand(XMPPIOService service, Packet packet) Process command execution which may be sent from other component and should be processed by processorbooleanRegistrationThrottlingProcessor.processIncoming(XMPPIOService service, Packet packet) booleanStreamErrorCounterIOProcessor.processIncoming(XMPPIOService service, Packet packet) booleanStreamManagementIOProcessor.processIncoming(XMPPIOService service, Packet packet) booleanXMPPIOProcessor.processIncoming(XMPPIOService service, Packet packet) Process packets read from socket as they are sent to SessionManager.booleanRegistrationThrottlingProcessor.processOutgoing(XMPPIOService service, Packet packet) booleanStreamErrorCounterIOProcessor.processOutgoing(XMPPIOService service, Packet packet) booleanStreamManagementIOProcessor.processOutgoing(XMPPIOService service, Packet packet) booleanXMPPIOProcessor.processOutgoing(XMPPIOService service, Packet packet) Process outgoing packets as they are added to XMPPIOService outgoing packets queue.voidClientConnectionManager.processPacket(Packet packet) booleanClientConnectionManager.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) Constructors in tigase.server.xmppclient with parameters of type Packet -
Uses of Packet in tigase.server.xmppcomponent
Methods in tigase.server.xmppcomponent that return types with arguments of type PacketModifier and TypeMethodDescriptionComponentConnectionManager.processSocketData(XMPPIOService<Object> serv) Deprecated.Methods in tigase.server.xmppcomponent with parameters of type PacketModifier and TypeMethodDescriptionprotected StringComponentConnectionManager.getServiceId(Packet packet) Deprecated.voidComponentConnectionManager.processPacket(Packet packet) Deprecated.booleanComponentConnectionManager.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) Deprecated. -
Uses of Packet in tigase.server.xmppserver
Methods in tigase.server.xmppserver that return types with arguments of type PacketMethods in tigase.server.xmppserver with parameters of type PacketModifier and TypeMethodDescriptionvoidS2SConnection.addControlPacket(Packet packet) booleanS2SConnectionHandlerIfc.addOutPacket(Packet packet) booleanS2SConnectionManager.addOutPacket(Packet packet) booleanS2SFilterIfc.filter(Packet p, S2SIOService serv, Queue<Packet> results) intS2SConnectionManager.hashCodeForPacket(Packet packet) booleanS2SProcessor.process(Packet p, S2SIOService serv, Queue<Packet> results) voidS2SConnectionManager.processPacket(Packet packet) booleanS2SConnectionManager.processUndeliveredPacket(Packet packet, Long stamp, String errorMessage) S2SConnectionSelector.selectConnection(Packet packet, Set<S2SConnection> outgoing) S2SRandomSelector.selectConnection(Packet packet, Set<S2SConnection> outgoing) booleanCIDConnections.sendControlPacket(String sessionId, Packet packet) voidCIDConnections.sendHandshakingOnly(Packet verify_req) voidCIDConnections.sendPacket(Packet packet) booleanS2SConnection.sendPacket(Packet packet) default booleanS2SProcessor.shouldSkipUndelivered(Packet packet) Method determines whether not delivered packet (due to closed connection) should be skipped and not added for re-delivery.booleanS2SConnectionHandlerIfc.writePacketToSocket(IO serv, Packet packet) Method parameters in tigase.server.xmppserver with type arguments of type PacketModifier and TypeMethodDescriptionbooleanS2SFilterIfc.filter(Packet p, S2SIOService serv, Queue<Packet> results) booleanS2SProcessor.process(Packet p, S2SIOService serv, Queue<Packet> results) voidS2SConnectionHandlerIfc.writePacketsToSocket(IO serv, Queue<Packet> packets) -
Uses of Packet in tigase.server.xmppserver.proc
Methods in tigase.server.xmppserver.proc with parameters of type PacketModifier and TypeMethodDescriptionvoidAuthenticatorSelectorManager.authenticationFailed(Packet packet, S2SIOService serv, AuthenticationProcessor processor, Queue<Packet> results) booleanDialback.canHandle(Packet p, S2SIOService serv, Queue<Packet> results) booleanSaslExternal.canHandle(Packet p, S2SIOService serv, Queue<Packet> results) booleanPacketChecker.filter(Packet p, S2SIOService serv, Queue<Packet> results) booleanStreamFeatures.filter(Packet p, S2SIOService serv, Queue<Packet> results) booleanAuthenticatorSelectorManager.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 booleanPacketChecker.isAllowed(Packet p, S2SIOService serv, CID cid) Check if incoming packet is allowed on this connectionbooleanDialback.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanS2SAbstractProcessor.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanSaslExternal.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanStartTLS.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanStreamError.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanStreamFeatures.process(Packet p, S2SIOService serv, Queue<Packet> results) voidDialback.restartAuth(Packet packet, S2SIOService serv, Queue<Packet> results) voidSaslExternal.restartAuth(Packet p, S2SIOService serv, Queue<Packet> results) booleanDialback.shouldSkipUndelivered(Packet packet) booleanSaslExternal.shouldSkipUndelivered(Packet packet) booleanStartTLS.shouldSkipUndelivered(Packet packet) booleanStartZlib.shouldSkipUndelivered(Packet packet) booleanStreamFeatures.shouldSkipUndelivered(Packet packet) Method parameters in tigase.server.xmppserver.proc with type arguments of type PacketModifier and TypeMethodDescriptionvoidAuthenticatorSelectorManager.authenticationFailed(Packet packet, S2SIOService serv, AuthenticationProcessor processor, Queue<Packet> results) booleanDialback.canHandle(Packet p, S2SIOService serv, Queue<Packet> results) booleanSaslExternal.canHandle(Packet p, S2SIOService serv, Queue<Packet> results) booleanPacketChecker.filter(Packet p, S2SIOService serv, Queue<Packet> results) booleanStreamFeatures.filter(Packet p, S2SIOService serv, Queue<Packet> results) booleanAuthenticatorSelectorManager.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 futuresbooleanDialback.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanS2SAbstractProcessor.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanSaslExternal.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanStartTLS.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanStreamError.process(Packet p, S2SIOService serv, Queue<Packet> results) booleanStreamFeatures.process(Packet p, S2SIOService serv, Queue<Packet> results) voidDialback.restartAuth(Packet packet, S2SIOService serv, Queue<Packet> results) voidSaslExternal.restartAuth(Packet p, S2SIOService serv, Queue<Packet> results) -
Uses of Packet in tigase.server.xmppsession
Methods in tigase.server.xmppsession that return PacketMethods in tigase.server.xmppsession with parameters of type PacketModifier and TypeMethodDescriptionbooleanSessionManager.addOutPacket(Packet packet) protected voidSessionManager.addOutPackets(Packet packet, XMPPResourceConnection conn, Queue<Packet> results) voidSessionManager.MessageArchive.addStableId(Packet packet, XMPPResourceConnection session) booleanPacketDefaultHandler.canHandle(Packet packet, XMPPResourceConnection session) Method checks if packet can be processed by this handlerprotected booleanSessionManager.fastAddOutPacket(Packet packet) booleanPacketDefaultHandler.forward(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidSessionManager.MessageArchive.generateStableId(Packet packet) protected XMPPResourceConnectionSessionManager.getXMPPResourceConnection(Packet p) voidSessionManager.handleLocalPacket(Packet packet, XMPPResourceConnection conn) intSessionManager.hashCodeForPacket(Packet packet) protected booleanSessionManager.isBrokenPacket(Packet p) booleanPacketDefaultHandler.preprocess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidPacketDefaultHandler.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidSessionManager.DefaultHandlerProc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionManager.SessionCloseProc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionManager.SessionOpenProc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected booleanSessionManager.processAdminsOrDomains(Packet packet) protected booleanSessionManager.processCommand(Packet pc) voidSessionManager.processPacket(Packet packet) protected voidSessionManager.processPacket(Packet packet, XMPPResourceConnection conn) protected voidSessionManager.sendToAdmins(Packet packet) booleanSessionManager.MessageArchive.willArchive(Packet packet, XMPPResourceConnection session) voidSessionManager.ProcessorResultWriter.write(Packet packet, XMPPResourceConnection session, Queue<Packet> results) voidvoidSessionManager.SMPacketWriter.write(Packet packet, AsyncCallback callback) Method parameters in tigase.server.xmppsession with type arguments of type PacketModifier and TypeMethodDescriptionprotected voidSessionManager.addOutPackets(Packet packet, XMPPResourceConnection conn, Queue<Packet> results) booleanPacketDefaultHandler.forward(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) booleanPacketDefaultHandler.preprocess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidPacketDefaultHandler.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidSessionManager.DefaultHandlerProc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionManager.SessionCloseProc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionManager.SessionOpenProc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionManager.ProcessorResultWriter.write(Packet packet, XMPPResourceConnection session, Queue<Packet> results) voidSessionManager.SMPacketWriter.write(Collection<Packet> packets) Constructors in tigase.server.xmppsession with parameters of type Packet -
Uses of Packet in tigase.stats
Methods in tigase.stats with parameters of type PacketModifier and TypeMethodDescriptionvoidStatisticsCollector.processPacket(Packet packet, Queue<Packet> results) Deprecated.Method parameters in tigase.stats with type arguments of type PacketModifier and TypeMethodDescriptionvoidStatisticsCollector.processPacket(Packet packet, Queue<Packet> results) Deprecated. -
Uses of Packet in tigase.util.processing
Methods in tigase.util.processing that return PacketMethods in tigase.util.processing with parameters of type PacketModifier and TypeMethodDescriptionbooleanProcessingThreads.addItem(XMPPProcessorIfc processor, Packet packet, XMPPResourceConnection conn) Constructors in tigase.util.processing with parameters of type PacketModifierConstructorDescriptionQueueItem(XMPPProcessorIfc processor, Packet packet, XMPPResourceConnection conn) -
Uses of Packet in tigase.util.tracer
Methods in tigase.util.tracer with parameters of type PacketModifier and TypeMethodDescriptionbooleanTigaseTracer.trace(String ip, String to_jid, String from_jid, String cid, String id, String point, String msg, Packet packet) booleanTigaseTracer.traceByCid(String cid, String point, String msg, Packet packet) booleanTigaseTracer.traceByFromJid(String jid, String point, String msg, Packet packet) booleanTigaseTracer.traceByToJid(String jid, String point, String msg, Packet packet) booleanTigaseTracer.tracegByIP(String ip, String point, String msg, Packet packet) -
Uses of Packet in tigase.vhosts
Methods in tigase.vhosts with parameters of type PacketModifier and TypeMethodDescriptionvoidVHostItemExtensionIfc.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.voidVHostItemImpl.addCommandFields(Packet packet) voidVHostItemImpl.VHostItemWrapper.addCommandFields(Packet packet) voidVHostItemExtensionIfc.initFromCommand(String prefix, Packet packet) Method initializes instance of a class with values provided by the user using ad-hoc command.voidVHostItemImpl.initFromCommand(Packet packet) voidVHostItemImpl.VHostItemWrapper.initFromCommand(Packet packet) -
Uses of Packet in tigase.xmpp
Methods in tigase.xmpp that return PacketModifier 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) Methods in tigase.xmpp that return types with arguments of type PacketModifier and TypeMethodDescriptionXMPPIOService.getReceivedPackets()XMPPIOService.getWaitingForAct()XMPPIOService.getWaitingPackets()Returns queue with packets waiting to send.Methods in tigase.xmpp with parameters of type PacketModifier and TypeMethodDescriptionvoidXMPPIOService.addPacketToSend(Packet packet) MethodaddPacketToSendadds new data which will be processed during next run.protected voidXMPPIOService.addReceivedPacket(Packet packet) MethodaddReceivedPacketputs 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) voidXMPPPacketFilterIfc.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 booleanXMPPProcessorAbstract.isFromUserSession(Packet packet, XMPPResourceConnection session) static booleanXMPPProcessorAbstract.isNullSession(Packet packet, XMPPResourceConnection session) static booleanXMPPProcessorAbstract.isServerSession(Packet packet, XMPPResourceConnection session) static booleanXMPPProcessorAbstract.isToUserSession(Packet packet, XMPPResourceConnection session) XMPPProcessorException.makeElement(Packet packet, boolean insertOriginal) booleanvoidXMPPPostprocessorIfc.postProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs processing ofpacketfor which there was no processor.booleanXMPPPreprocessorIfc.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket.voidXMPPProcessorAbstract.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidXMPPProcessorIfc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidXMPPProcessorAbstract.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....).voidXMPPProcessorAbstract.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 voidXMPPProcessorAbstract.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...).voidXMPPProcessorAbstract.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 voidXMPPProcessorAbstract.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.voidXMPPProcessorAbstract.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 booleanXMPPIOService.shouldCountPacket(Packet packet) Method parameters in tigase.xmpp with type arguments of type PacketModifier and TypeMethodDescriptionvoidXMPPPacketFilterIfc.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidXMPPPostprocessorIfc.postProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs processing ofpacketfor which there was no processor.booleanXMPPPreprocessorIfc.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket.voidXMPPProcessorAbstract.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidXMPPProcessorIfc.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidXMPPProcessorAbstract.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....).voidXMPPProcessorAbstract.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 voidXMPPProcessorAbstract.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...).voidXMPPProcessorAbstract.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 voidXMPPProcessorAbstract.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.voidXMPPProcessorAbstract.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.voidXMPPStopListenerIfc.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
Methods in tigase.xmpp.impl that return PacketModifier and TypeMethodDescriptionprotected PacketSaslAuthAbstract.createSaslErrorResponse(XmppSaslException.SaslError error, String message, Packet packet) static PacketC2SDeliveryErrorProcessor.makeDeliveryError(Packet packet, Long stamp) Creates delivery-error packets to send to session manager to reprocess undelivered packetsstatic PacketPresenceCapabilitiesManager.prepareCapsQuery(JID to, JID from, String node) protected PacketJabberIqPrivacy.prepareError(Packet packet, XMPPResourceConnection session) static PacketPresenceAbstract.sendPresence(StanzaType t, JID from, JID to, Queue<Packet> results, Element pres) Sends Presence stanza from provided parameters as well as returns created resultPacketobject.Methods in tigase.xmpp.impl that return types with arguments of type PacketModifier 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.Methods in tigase.xmpp.impl with parameters of type PacketModifier and TypeMethodDescriptionvoidPresenceSubscription.PresenceSubscriptionVHostItemExtension.addCommandFields(String prefix, Packet packet, boolean forDefault) protected booleanJabberIqPrivacy.allowed(Packet packet, JID connId, BareJID userJid, PrivacyList privacyList) protected booleanJabberIqPrivacy.allowed(Packet packet, XMPPResourceConnection session) protected booleanJabberIqPrivacy.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) intvoidprotected PacketSaslAuthAbstract.createSaslErrorResponse(XmppSaslException.SaslError error, String message, Packet packet) protected voidJabberIqRegister.doGetRegistrationForm(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRegister.doRemoveAccount(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected static voidJabberIqRoster.dynamicGetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostergetrequest related to dynamic roster.protected static voidJabberIqRoster.dynamicSetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostersetrequest related to dynamic roster.static voidC2SDeliveryErrorProcessor.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, JID toIgnore) Filters packets created by processors to remove delivery-error payloadvoidClientStateIndication.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidDomainFilter.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidErrorCounter.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidJabberIqPrivacy.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMessage.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMessageAmp.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMessageCarbons.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMobileV1.filter(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) voidMobileV2.filter(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) voidMobileV3.filter(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) protected static voidPresenceAbstract.forwardPresence(Queue<Packet> results, Packet packet, JID from) Simply forwards packet to the destinationstatic ElementC2SDeliveryErrorProcessor.getDeliveryError(Packet packet) Finds delivery-error element in packet and returns itprotected static longLastActivityAbstract.getLastActivity(XMPPResourceConnection session, Packet packet) voidMessageDeliveryLogic.handleDelivery(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPresenceSubscription.PresenceSubscriptionVHostItemExtension.initFromCommand(String prefix, Packet packet) protected booleanOfflineMessages.isAllowedForOfflineStorage(Packet pac) Method determines whether packet sent to offline user should be stored in offline storage or notprotected booleanOfflineMessages.isAllowedForOfflineStorageDefaults(Packet pac) static booleanC2SDeliveryErrorProcessor.isDeliveryError(Packet packet) Checks if packet is delivery-error packetprotected booleanAbstractAuthPreprocessor.isPacketAllowed(Packet packet) protected booleanOfflineMessages.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 PacketC2SDeliveryErrorProcessor.makeDeliveryError(Packet packet, Long stamp) Creates delivery-error packets to send to session manager to reprocess undelivered packetsvoidOfflineMessages.Notifier.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) protected voidOfflineMessages.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) voidOfflineMessages.PubSubPublisherNotifier.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) voidVCardTemp.pepToVCardTemp_onDataRetrieved(Packet packet, XMPPResourceConnection session) voidMessageAmp.postProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidOfflineMessages.postProcess(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> queue, Map<String, Object> settings) Performs processing ofpacketfor which there was no processor.protected PacketJabberIqPrivacy.prepareError(Packet packet, XMPPResourceConnection session) MessageCarbons.prepareSkipForkingToList(Packet packet, XMPPResourceConnection session, Map<JID, Boolean> resources) booleanAbstractAuthPreprocessor.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanAddressingSanitizer.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static booleanC2SDeliveryErrorProcessor.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 availablebooleanDomainFilter.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanInvisibleCommand.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanJabberIqIq.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanJabberIqPrivacy.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket.booleanMessage.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanMessageAmp.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanStartTLS.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanMessageDeliveryLogic.preProcessFilter(Packet packet, XMPPResourceConnection session) voidBindResource.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidBlockingCommand.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidCAPS.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidClientStateIndication.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidErrorCounter.process(Packet packet, XMPPResourceConnection session) voidInvisibleCommand.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqAuth.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqCommand.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqIq.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqPrivacy.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqPrivate.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqRegister.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 APIvoidJabberIqRoster.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.voidJabberIqStats.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJingle.process(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository nonAuthUserRepo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivityMarker.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessage.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageAll.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageAmp.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageCarbons.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageForwarding.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMIXProcessor.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMobileV1.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMobileV2.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMobileV3.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMotdProcessor.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidOfflineMessages.process(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
OfflineMessagesprocessor is triggered by<presence>stanza.voidPresenceOffline.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPresenceState.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.PresenceTypevoidPresenceSubscription.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.PresenceTypevoidSaslAuth.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSaslAuth2.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServerInfo.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServiceDiscovery.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionBind.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSimpleForwarder.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidStartTLS.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidStartZLib.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static voidPresenceCapabilitiesManager.processCapsQueryResponse(Packet packet) protected voidPresenceState.processError(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Process presence stanza of type Error.voidEntityTime.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processFromUserPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processFromUserPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidBlockingCommand.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidEntityTime.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidFlexibleOfflineMessageRetrieval.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPepPlugin.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Deprecated.voidRemoteRosterManagement.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServiceDiscovery.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidUrnXmppPing.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidJabberIqPrivacy.processGetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRoster.processGetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostergetrequest.protected voidPresenceState.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 voidPresenceState.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 voidPresenceSubscription.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 voidPresenceSubscription.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 voidPresenceSubscription.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 voidPresenceSubscription.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.voidOfflineMessages.processIq(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results) voidEntityTime.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPepPlugin.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Deprecated.voidServiceDiscovery.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidUrnXmppPing.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidPresenceState.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 voidPresenceSubscription.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 voidPresenceSubscription.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) voidBlockingCommand.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidEntityTime.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidFlexibleOfflineMessageRetrieval.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPepPlugin.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Deprecated.voidRemoteRosterManagement.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServiceDiscovery.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidUrnXmppPing.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidSaslAuthAbstract.processSessionAlreadyAuthorized(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqPrivacy.processSetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRoster.processSetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostersetrequest.protected voidSaslAuth.processSuccess(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected voidSaslAuth2.processSuccess(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected abstract voidSaslAuthAbstract.processSuccess(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) voidEntityTime.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidRemoteRosterManagement.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidAddressingSanitizer.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 booleanMobileV1.shouldBeQueued(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Queue<Packet> queue) protected booleanMobileV2.shouldBeQueued(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Map<JID, Packet> queue) protected booleanMessageCarbons.shouldSendCarbons(Packet packet, XMPPResourceConnection session) static voidPresenceAbstract.updatePresenceChange(Packet presence, XMPPResourceConnection session, Queue<Packet> results) updatePresenceChangemethod is used to broadcast to all active resources presence stanza received from other users, like incoming availability presence, subscription presence and so on...Method parameters in tigase.xmpp.impl with type arguments of type PacketModifier and TypeMethodDescriptionvoidClientStateIndication.Logic.activate(XMPPResourceConnection session, Queue<Packet> results) voidMobileV1.activate(XMPPResourceConnection session, Queue<Packet> results) voidMobileV2.activate(XMPPResourceConnection session, Queue<Packet> results) protected static voidPresenceState.broadcastDirectPresences(StanzaType t, XMPPResourceConnection session, Queue<Packet> results, Element pres) broadcastDirectPresencesbroadcast a direct Presence from providedpresElementobject to the collection of JIDs stored in temporary session data under keyDIRECT_PRESENCE.static voidPresenceState.broadcastOffline(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract roster_util) sendPresenceBroadcastmethod broadcasts given presence to all buddies from roster and to all users to which direct presence was sent.voidPresenceAbstract.broadcastProbe(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) sendPresenceBroadcastmethod broadcasts given presence to all buddies from roster and to all users to which direct presence was sent.protected voidPresenceState.buddyOnline(XMPPResourceConnection session, JID buddy, Queue<Packet> results, boolean online) Method sends back presence to contact while it becomes online (i.e.voidClientStateIndication.Logic.deactivate(XMPPResourceConnection session, Queue<Packet> results) voidMobileV1.deactivate(XMPPResourceConnection session, Queue<Packet> results) voidMobileV2.deactivate(XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRegister.doGetRegistrationForm(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRegister.doRemoveAccount(Packet packet, Element request, XMPPResourceConnection session, Queue<Packet> results) protected static voidJabberIqRoster.dynamicGetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostergetrequest related to dynamic roster.protected static voidJabberIqRoster.dynamicSetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostersetrequest related to dynamic roster.default ElementPresenceState.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 voidC2SDeliveryErrorProcessor.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, JID toIgnore) Filters packets created by processors to remove delivery-error payloadvoidClientStateIndication.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidDomainFilter.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidErrorCounter.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidJabberIqPrivacy.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMessage.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMessageAmp.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMessageCarbons.filter(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results) voidMobileV1.filter(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) voidMobileV2.filter(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) voidMobileV3.filter(Packet _packet, XMPPResourceConnection sessionFromSM, NonAuthUserRepository repo, Queue<Packet> results) protected voidMobileV1.flushQueue(XMPPResourceConnection session, Queue<Packet> results) protected voidMobileV2.flushQueue(XMPPResourceConnection session, Queue<Packet> results) protected static voidPresenceAbstract.forwardPresence(Queue<Packet> results, Packet packet, JID from) Simply forwards packet to the destinationvoidMessageDeliveryLogic.handleDelivery(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static voidPresenceCapabilitiesManager.handlePresence(JID owner, JID from, String[] capsNodes, Queue<Packet> results) voidPresenceCapabilitiesManager.PresenceCapabilitiesListener.handlePresence(JID owner, JID sender, String[] capsNodes, Queue<Packet> results) voidOfflineMessages.Notifier.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) protected voidOfflineMessages.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) voidOfflineMessages.PubSubPublisherNotifier.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection conn, Queue<Packet> queue, Map<String, Object> settings) default voidOfflineMessages.Notifier.notifyOfflineMessagesRetrieved(XMPPResourceConnection session, Queue<Packet> results) protected voidOfflineMessages.notifyOfflineMessagesRetrieved(XMPPResourceConnection conn, Queue<Packet> queue) voidVCardTemp.pepToVCardTemp_onPublication(BareJID userJid, XMPPResourceConnection session, String itemId, String mimeType, Supplier<JID> pubsubComponentJidSupplier, Consumer<Packet> writer) voidMessageAmp.postProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidOfflineMessages.postProcess(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> queue, Map<String, Object> settings) Performs processing ofpacketfor which there was no processor.static voidPresenceCapabilitiesManager.prepareCapsQueries(JID compJid, JID to, String[] caps_nodes, Queue<Packet> results) booleanAbstractAuthPreprocessor.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanAddressingSanitizer.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) static booleanC2SDeliveryErrorProcessor.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 availablebooleanDomainFilter.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanInvisibleCommand.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanJabberIqIq.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanJabberIqPrivacy.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Performs pre-processing ofpacket.booleanMessage.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanMessageAmp.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) booleanStartTLS.preProcess(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidBindResource.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidBlockingCommand.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidCAPS.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidClientStateIndication.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidInvisibleCommand.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqAuth.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqCommand.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqIq.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqPrivacy.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqPrivate.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqRegister.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 APIvoidJabberIqRoster.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.voidJabberIqStats.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJingle.process(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository nonAuthUserRepo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivityMarker.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessage.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageAll.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageAmp.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageCarbons.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMessageForwarding.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMIXProcessor.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMobileV1.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMobileV2.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMobileV3.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidMotdProcessor.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidOfflineMessages.process(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings)
OfflineMessagesprocessor is triggered by<presence>stanza.voidPresenceOffline.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPresenceState.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.PresenceTypevoidPresenceSubscription.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.PresenceTypevoidSaslAuth.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSaslAuth2.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServerInfo.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServiceDiscovery.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSessionBind.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidSimpleForwarder.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidStartTLS.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidStartZLib.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidPresenceState.processError(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings, RosterAbstract.PresenceType presenceType) Process presence stanza of type Error.voidEntityTime.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processFromUserOutPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processFromUserPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processFromUserPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidBlockingCommand.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidEntityTime.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidFlexibleOfflineMessageRetrieval.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPepPlugin.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Deprecated.voidRemoteRosterManagement.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServiceDiscovery.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidUrnXmppPing.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processFromUserToServerPacket(JID connectionId, Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidJabberIqPrivacy.processGetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRoster.processGetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostergetrequest.protected voidPresenceState.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 voidPresenceState.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 voidPresenceSubscription.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 voidPresenceSubscription.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 voidPresenceSubscription.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 voidPresenceSubscription.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.voidOfflineMessages.processIq(Packet packet, XMPPResourceConnection conn, NonAuthUserRepository repo, Queue<Packet> results) voidEntityTime.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPepPlugin.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Deprecated.voidServiceDiscovery.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidUrnXmppPing.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processNullSessionPacket(Packet packet, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidPresenceState.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 voidPresenceSubscription.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 voidPresenceSubscription.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) voidBlockingCommand.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidEntityTime.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidFlexibleOfflineMessageRetrieval.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidJabberIqVersion.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPepPlugin.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) Deprecated.voidRemoteRosterManagement.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidServiceDiscovery.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidUrnXmppPing.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processServerSessionPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) protected voidSaslAuthAbstract.processSessionAlreadyAuthorized(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqPrivacy.processSetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results) protected voidJabberIqRoster.processSetRequest(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) Method processes rostersetrequest.protected voidSaslAuth.processSuccess(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected voidSaslAuth2.processSuccess(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) protected abstract voidSaslAuthAbstract.processSuccess(Packet packet, XMPPResourceConnection session, String challengeData, Queue<Packet> results) voidEntityTime.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidLastActivity.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidRemoteRosterManagement.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCard4.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidVCardTemp.processToUserPacket(Packet packet, XMPPResourceConnection session, NonAuthUserRepository repo, Queue<Packet> results, Map<String, Object> settings) voidPresenceState.rebroadcastPresence(XMPPResourceConnection session, Queue<Packet> results) voidPresenceState.resendPendingInRequests(XMPPResourceConnection session, Queue<Packet> results) Sends out all pending subscription request during user log-in.static voidPresenceAbstract.sendPresence(StanzaType t, BareJID from, BareJID to, Queue<Packet> results, Element pres) Sends Presence stanza from provided parameters without returning created resultPacketobject.static PacketPresenceAbstract.sendPresence(StanzaType t, JID from, JID to, Queue<Packet> results, Element pres) Sends Presence stanza from provided parameters as well as returns created resultPacketobject.static voidPresenceState.sendPresenceBroadcast(StanzaType t, XMPPResourceConnection session, EnumSet<RosterAbstract.SubscriptionType> subscrs, Queue<Packet> results, Element pres, Map<String, Object> settings, RosterAbstract roster_util) sendPresenceBroadcastmethod broadcasts given presence to all buddies from roster and to all users to which direct presence was sent.protected voidPresenceState.sendRosterOfflinePresence(XMPPResourceConnection session, Queue<Packet> results) Method sends server generated presence unavailable for all buddies from the roster with a custom status message.voidMIXProcessor.sendToChannel(BareJID userJid, String resource, BareJID channel, String requestStanzaId, Element joinEl, Consumer<Packet> writer) protected voidMIXProcessor.sendToChannel(BareJID userJID, BareJID channel, String id, Element actionEl, Consumer<Packet> writer) protected voidMIXProcessor.sendToUser(BareJID userJID, String resource, JID connectionJID, StanzaType stanzaType, String id, Element actionEl, Element errorEl, Consumer<Packet> writer) protected booleanMobileV1.shouldBeQueued(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Queue<Packet> queue) protected booleanMobileV2.shouldBeQueued(XMPPResourceConnection session, Packet currentlyFilteredResultPacket, Map<JID, Packet> queue) voidLastActivityMarker.stopped(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) voidPresenceOffline.stopped(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) voidPresenceState.stopped(XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> settings) static voidRemoteRosterManagement.updateBuddyChange(XMPPResourceConnection session, Element item, Element update, Queue<Packet> results) protected static voidPresenceState.updateOfflineChange(XMPPResourceConnection session, Queue<Packet> results) updateOfflineChangemethod broadcast off-line presence to all other user active resources.static voidPresenceAbstract.updatePresenceChange(Packet presence, XMPPResourceConnection session, Queue<Packet> results) updatePresenceChangemethod is used to broadcast to all active resources presence stanza received from other users, like incoming availability presence, subscription presence and so on...static voidPresenceAbstract.updateUserResources(Element presence, XMPPResourceConnection session, Queue<Packet> results, boolean initial) updateUserResourcesmethod is used to broadcast to all other resources presence stanza from one user resource. -
Uses of Packet in tigase.xmpp.impl.push
Methods in tigase.xmpp.impl.push with parameters of type PacketModifier and TypeMethodDescriptionprotected booleanIgnoreFromUnknownFilter.isInRoster(Packet packet, XMPPResourceConnection session) protected booleanGroupchatFilter.isMentioned(Packet packet, String nick) protected booleanAbstractPushNotifications.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) booleanGroupchatFilter.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) booleanIgnoreFromUnknownFilter.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) booleanJinglePushNotificationsExtension.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) booleanMutedFilter.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) protected booleanPushNotifications.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) booleanPushNotificationsFilter.isSendingNotificationAllowed(BareJID userJid, XMPPResourceConnection session, Element pushServiceSettings, Packet packet) voidPushNotifications.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> map) protected ElementAbstractPushNotifications.prepareNotificationPayload(Element pushServiceSettings, PushNotificationCause cause, Packet packet, long msgCount) voidEncryptedPushNotificationExtension.prepareNotificationPayload(Element pushServiceSettings, PushNotificationCause cause, Packet packet, long msgCount, Element notification) voidPriorityExtension.prepareNotificationPayload(Element pushServiceSettings, PushNotificationCause cause, Packet packet, long msgCount, Element notification) protected ElementPushNotifications.prepareNotificationPayload(Element pushServiceSettings, PushNotificationCause cause, Packet packet, long msgCount) default voidPushNotificationsExtension.prepareNotificationPayload(Element pushServiceSettings, Packet packet, long msgCount, Element notification) default voidPushNotificationsExtension.prepareNotificationPayload(Element pushServiceSettings, PushNotificationCause cause, Packet packet, long msgCount, Element notification) voidAbstractPushNotifications.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) voidPushNotifications.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) protected voidAbstractPushNotifications.processMessage(Packet packet, XMPPResourceConnection session, Consumer<Packet> results) protected voidPushNotifications.processMessage(Packet packet, XMPPResourceConnection session, Consumer<Packet> consumer) protected voidAbstractPushNotifications.sendPushNotification(BareJID userJid, Collection<Element> pushServices, XMPPResourceConnection session, PushNotificationCause cause, Packet packet, Map<Enum, Long> notificationData, Consumer<Packet> packetConsumer) protected voidAbstractPushNotifications.sendPushNotification(XMPPResourceConnection session, PushNotificationCause cause, Packet packet, Consumer<Packet> packetConsumer) booleanAwayPushNotificationsExtension.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) booleanEncryptedPushNotificationExtension.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) booleanGroupchatPushNotificationsExtension.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) booleanJinglePushNotificationsExtension.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) booleanPriorityExtension.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) protected booleanPushNotifications.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) booleanPushNotificationsExtension.shouldSendNotification(Packet packet, BareJID userJid, XMPPResourceConnection session) Method parameters in tigase.xmpp.impl.push with type arguments of type PacketModifier and TypeMethodDescriptionvoidPushPresence.broadcastPresenceFromPushDevices(BareJID userJid, boolean hasPushDevices, Consumer<Packet> packetConsumer) protected voidAbstractPushNotifications.disableNotifications(XMPPResourceConnection session, BareJID userJid, JID jid, String node, Consumer<Packet> packetConsumer) protected voidAbstractPushNotifications.enableNotifications(XMPPResourceConnection session, JID jid, String node, Element settings, Consumer<Packet> packetConsumer) protected voidAbstractPushNotifications.enableNotifications(XMPPResourceConnection session, JID jid, String node, Element enableElem, Element optionsForm, Consumer<Packet> packetConsumer) voidPushNotifications.notifyNewOfflineMessage(Packet packet, XMPPResourceConnection session, Queue<Packet> results, Map<String, Object> map) protected voidPushNotifications.notifyOfflineMessagesRetrieved(BareJID userJid, Collection<Element> pushServices, Consumer<Packet> packetConsumer) voidPushNotifications.notifyOfflineMessagesRetrieved(XMPPResourceConnection session, Queue<Packet> results) voidAbstractPushNotifications.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) voidPushNotifications.process(Packet packet, XMPPResourceConnection session, NonAuthUserRepository nonAuthUserRepository, Queue<Packet> results, Map<String, Object> map) protected voidAbstractPushNotifications.processMessage(Packet packet, XMPPResourceConnection session, Consumer<Packet> results) protected voidPushNotifications.processMessage(Packet packet, XMPPResourceConnection session, Consumer<Packet> consumer) voidPushPresence.processPresenceProbe(JID recipient, JID sender, Consumer<Packet> packetConsumer) voidPushPresence.processPresenceToOffline(JID recipient, JID sender, StanzaType stanzaType, Consumer<Packet> packetConsumer) voidPushPresence.pushAvailabilityChanged(BareJID userJid, boolean newValue, Consumer<Packet> packetConsumer) protected voidAbstractPushNotifications.sendPushNotification(BareJID userJid, Collection<Element> pushServices, XMPPResourceConnection session, PushNotificationCause cause, Packet packet, Map<Enum, Long> notificationData, Consumer<Packet> packetConsumer) protected voidAbstractPushNotifications.sendPushNotification(XMPPResourceConnection session, PushNotificationCause cause, Packet packet, Consumer<Packet> packetConsumer) -
Uses of Packet in tigase.xmpp.impl.roster
Methods in tigase.xmpp.impl.roster that return types with arguments of type PacketModifier and TypeMethodDescriptionRosterAbstract.addJidToRoster(UserRepository repository, XMPPSession session, BareJID owner, RosterElement rosterElement) RosterAbstract.removeJidFromRoster(UserRepository repository, XMPPSession session, BareJID owner, JID jid) Deprecated.Methods in tigase.xmpp.impl.roster with parameters of type PacketModifier and TypeMethodDescriptionRosterAbstract.getPresenceType(XMPPResourceConnection session, Packet packet) Method parameters in tigase.xmpp.impl.roster with type arguments of type PacketModifier and TypeMethodDescriptionvoidRosterAbstract.updateBuddyChange(XMPPResourceConnection session, Queue<Packet> results, Element item) -
Uses of Packet in tigase.xmpp.mam
Methods in tigase.xmpp.mam with parameters of type PacketModifier 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 ElementQueryParser.prepareForm(Element elem, String xmlns, Packet packet) -
Uses of Packet in tigase.xmpp.mam.modules
Methods in tigase.xmpp.mam.modules with parameters of type Packet