Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
ClusterConnectionManager.processSocketData(XMPPIOService<Object> serv) |
Modifier and Type | Method and Description |
---|---|
boolean |
SessionManagerClustered.fastAddOutPacket(Packet packet) |
protected void |
AmpComponentClustered.forwardPacket(Packet packet) |
XMPPResourceConnection |
SessionManagerClustered.getXMPPResourceConnection(Packet p) |
void |
SessionManagerClustered.handleLocalPacket(Packet packet,
XMPPResourceConnection conn) |
int |
ClusterConnectionManager.hashCodeForPacket(Packet packet) |
void |
ClusterConnectionManager.processOutPacket(Packet packet) |
void |
ClusterConnectionManager.processPacket(Packet packet) |
void |
SessionManagerClustered.processPacket(Packet packet)
This is the main
Packet processing method. |
void |
AmpComponentClustered.processPacket(Packet packet) |
void |
VirtualComponent.processPacket(Packet packet,
Queue<Packet> results) |
void |
ClusterController.processPacket(Packet packet,
Queue<Packet> results) |
void |
SessionManagerClustered.processPacket(Packet packet,
XMPPResourceConnection conn) |
boolean |
ClusterConnectionManager.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage) |
XMPPIOService<Object> |
ClusterConnectionSelector.selectConnection(Packet p,
ClusterConnection conn) |
XMPPIOService<Object> |
ClusterConnectionSelectorOld.selectConnection(Packet p,
ClusterConnection conn) |
protected boolean |
ClusterConnectionManager.writePacketToSocket(Packet p) |
Modifier and Type | Method and Description |
---|---|
void |
VirtualComponent.processPacket(Packet packet,
Queue<Packet> results) |
void |
ClusterController.processPacket(Packet packet,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterElement.addDataPacket(Packet packet)
Method description
|
boolean |
SessionManagerClusteredIfc.fastAddOutPacket(Packet packet)
Method description
|
XMPPResourceConnection |
SessionManagerClusteredIfc.getXMPPResourceConnection(Packet el_packet)
Method description
|
int |
ClusterConnectionHandler.hashCodeForPacket(Packet packet)
Generates hashCode for particular packet used to spread processing between
thread or connections
|
void |
SessionManagerClusteredIfc.processPacket(Packet el_packet,
XMPPResourceConnection conn)
Method description
|
XMPPIOService<Object> |
ClusterConnectionSelectorIfc.selectConnection(Packet packet,
ClusterConnection conn)
Method returns XMPPIOService instances which should be used to
send packet between cluster nodes
|
Constructor and Description |
---|
ClusterElement(JID from,
JID to,
StanzaType type,
Packet packet)
Constructs ...
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterRepoItem.addCommandFields(Packet packet) |
void |
ClusterRepoItem.initFromCommand(Packet packet) |
Modifier and Type | Method and Description |
---|---|
List<JID> |
DefaultClusteringStrategyAbstract.getNodesForPacketForward(JID fromNode,
Set<JID> visitedNodes,
Packet packet)
Method description
|
List<JID> |
DefaultClusteringStrategy.getNodesForPacketForward(JID fromNode,
Set<JID> visitedNodes,
Packet packet) |
List<JID> |
SMNonCachingAllNodes.getNodesForPacketForward(JID fromNode,
Set<JID> visitedNodes,
Packet packet)
Method description
|
void |
DefaultClusteringStrategyAbstract.handleLocalPacket(Packet packet,
XMPPResourceConnection conn) |
void |
DefaultClusteringStrategy.handleLocalPacket(Packet packet,
XMPPResourceConnection conn) |
void |
ClusteringStrategyIfc.handleLocalPacket(Packet packet,
XMPPResourceConnection conn)
Method description
|
protected boolean |
DefaultClusteringStrategyAbstract.isSuitableForForward(Packet packet)
Method description
|
protected boolean |
SMNonCachingAllNodes.isSuitableForForward(Packet packet)
Method description
|
boolean |
DefaultClusteringStrategyAbstract.processPacket(Packet packet,
XMPPResourceConnection conn) |
boolean |
ClusteringStrategyIfc.processPacket(Packet packet,
XMPPResourceConnection conn)
Method description
|
boolean |
DefaultClusteringStrategyAbstract.sendToNextNode(JID fromNode,
Set<JID> visitedNodes,
Map<String,String> data,
Packet packet)
Method attempts to send the packet to the next cluster node.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractComponent.addOutPacket(Packet packet,
AsyncCallback asyncCallback) |
void |
AbstractComponent.processPacket(Packet packet) |
protected void |
AbstractComponent.sendException(Packet packet,
ComponentException e)
Converts
ComponentException to XMPP error stanza and sends it to
sender of packet. |
void |
PacketWriter.write(Packet packet)
Writes single Packet.
|
void |
PacketWriter.write(Packet packet,
AsyncCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
PacketWriter.write(Collection<Packet> packets)
Writes collection of Packets.
|
Modifier and Type | Method and Description |
---|---|
Packet |
AdhHocRequest.getIq() |
Packet |
AdHocCommandManager.process(Packet packet)
Method description
|
Packet |
AdHocCommandManager.process(Packet packet,
Element commandElement,
String node,
String action,
String sessionId,
AdHocCommand adHocCommand) |
Modifier and Type | Method and Description |
---|---|
List<Packet> |
AdHocScriptCommandManager.process(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
AdHocCommandManager.process(Packet packet)
Method description
|
List<Packet> |
AdHocScriptCommandManager.process(Packet packet) |
Packet |
AdHocCommandManager.process(Packet packet,
Element commandElement,
String node,
String action,
String sessionId,
AdHocCommand adHocCommand) |
Modifier and Type | Method and Description |
---|---|
Packet |
ComponentException.makeElement(Packet packet,
boolean insertOriginal) |
Modifier and Type | Method and Description |
---|---|
Packet |
ComponentException.makeElement(Packet packet,
boolean insertOriginal) |
Modifier and Type | Method and Description |
---|---|
void |
Module.process(Packet packet)
Process incoming stanza.
|
boolean |
ModulesManager.process(Packet packet) |
protected void |
AbstractModule.write(Packet packet)
Writes single Packet.
|
protected void |
AbstractModule.write(Packet packet,
AsyncCallback asyncCallback) |
Modifier and Type | Method and Description |
---|---|
void |
DiscoveryModule.process(Packet packet) |
void |
XmppPingModule.process(Packet iq) |
void |
AdHocCommandModule.process(Packet packet) |
void |
JabberVersionModule.process(Packet packet) |
protected void |
DiscoveryModule.processAdHocCommandItems(Packet packet,
JID jid,
String node,
JID senderJID) |
protected void |
DiscoveryModule.processDiscoInfo(Packet packet,
JID jid,
String node,
JID senderJID) |
protected void |
DiscoveryModule.processDiscoItems(Packet packet,
JID jid,
String node,
JID senderJID) |
protected void |
AdHocCommandModule.processScriptAdHoc(Packet packet) |
boolean |
AdHocCommandModule.ScriptCommandProcessor.processScriptCommand(Packet pc,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
boolean |
AdHocCommandModule.ScriptCommandProcessor.processScriptCommand(Packet pc,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
Runnable |
ResponseManager.getResponseHandler(Packet element)
Returns handler for response of sent
<iq/> stanza. |
void |
AsyncCallback.onError(Packet responseStanza,
String errorCondition)
Called when received response has type error.
|
void |
AsyncCallback.onSuccess(Packet responseStanza)
Called when received response has type result.
|
String |
ResponseManager.registerResponseHandler(Packet stanza,
Long timeout,
AsyncCallback callback)
Register callback for response of sent
<iq/> stanza. |
Constructor and Description |
---|
DefaultResponseHandler(Packet packet,
ResponseManager.Entry entry) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigItem.addCommandFields(Packet packet) |
void |
ConfigItem.initFromCommand(Packet packet) |
void |
ConfiguratorOld.processPacket(Packet packet,
Queue<Packet> results) |
Object |
ConfiguratorOld.setPropertyValue(String key,
String val,
Packet result_pack,
boolean admin)
Method description
|
Modifier and Type | Method and Description |
---|---|
void |
ConfiguratorOld.processPacket(Packet packet,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
void |
RepositoryItemAbstract.addCommandFields(Packet packet) |
void |
RepositoryItem.addCommandFields(Packet packet)
The method is used for handling ad-hoc commands.
|
void |
RepositoryItemAbstract.initFromCommand(Packet packet) |
void |
RepositoryItem.initFromCommand(Packet packet)
The method used for handling ad-hoc commands.
|
Modifier and Type | Method and Description |
---|---|
void |
XMPPServiceCollector.processPacket(Packet packet,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
void |
XMPPServiceCollector.processPacket(Packet packet,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
void |
EventPublisherModule.process(Packet packet) |
void |
UnsubscribeModule.process(Packet packet) |
void |
EventReceiverModule.process(Packet packet) |
void |
SubscribeModule.process(Packet packet) |
protected Element |
SubscribeModule.processClusterSubscription(Packet packet) |
protected Element |
SubscribeModule.processNonClusterSubscription(Packet packet) |
void |
EventBusComponent.processPacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
AdHocCommandMonitorModule.process(Packet packet) |
protected void |
DiscoveryMonitorModule.processAdHocCommandItems(Packet packet,
JID jid,
String node,
JID senderJID) |
protected void |
DiscoveryMonitorModule.processDiscoInfo(Packet packet,
JID jid,
String node,
JID senderJID) |
protected void |
DiscoveryMonitorModule.processDiscoItems(Packet packet,
JID jid,
String node,
JID senderJID) |
Modifier and Type | Class and Description |
---|---|
class |
Iq
Created: Dec 31, 2009 8:43:21 PM
|
class |
Message
Created: Dec 31, 2009 8:38:38 PM
|
class |
Presence
Created: Dec 31, 2009 8:42:05 PM
|
Modifier and Type | Method and Description |
---|---|
Packet |
Iq.commandResult(Command.DataType cmd_type)
Method description
|
static Packet |
Iq.commandResultForm(Iq packet)
Method description
|
static Packet |
Iq.commandResultResult(Iq packet)
Method description
|
Packet |
Packet.copyElementOnly()
copyElementOnly method creates a copy of the packet with stanza
information copied only. |
Packet |
Packet.errorResult(String errorType,
Integer errorCode,
String errorCondition,
String errorText,
boolean includeOriginalXML)
Method returns a modified copy of the
Packet with its stanza as
stanza error used for reporting errors. |
Packet |
PacketFilterIfc.filter(Packet packet)
This is the actual packet filtering method.
|
static Packet |
Message.getMessage(JID from,
JID to,
StanzaType type,
String body,
String subject,
String thread,
String id)
Creates a packet with message stanza.
|
Packet |
Command.getPacket(JID from,
JID to,
StanzaType type,
String id)
Method returns instance of a Packet with command element added.
|
Packet |
Command.getPacket(JID from,
JID to,
StanzaType type,
String id,
Command.DataType data_type)
Method returns instance of a Packet with command element added.
|
Packet |
Packet.okResult(Element includeXML,
int originalXML)
Method returns a modified copy of the
Packet with its stanza as
stanza result used for reporting IQ stanza results. |
Packet |
Packet.okResult(String includeXML,
int originalXML)
Method returns a modified copy of the
Packet with its stanza as
stanza result used for reporting IQ stanza results. |
static Packet |
Packet.packetInstance(Element elem)
The method returns
Packet instance. |
static Packet |
Packet.packetInstance(Element elem,
JID stanzaFrom,
JID stanzaTo)
The method returns
Packet instance. |
static Packet |
Packet.packetInstance(String el_name,
String from,
String to,
StanzaType type)
The method creates XML stanza from given parameters and returns
Packet instance for this XML stanza. |
Packet |
Packet.packRouted()
Returns a new
Packet instance with stanza routed
which means an original stanza has been enclosed inside a route
XML element which contains additional information taken from
Packet packet instance internal attributes. |
Packet |
Packet.swapElemFromTo()
Deprecated.
Use
swapStanzaFromTo() instead. |
Packet |
Packet.swapElemFromTo(StanzaType type)
Deprecated.
Use
swapStanzaFromTo() instead. |
Packet |
Packet.swapFromTo()
Creates a new
Packet instance with swapped packet source and
destination addresses. |
Packet |
Packet.swapFromTo(Element el,
JID stanzaFrom,
JID stanzaTo)
The method creates a new instance of the
Packet class with the
packet source and destination addresses swapped and sets the given stanza
element plus source and destination addresses for the new stanza. |
Packet |
Packet.swapStanzaFromTo()
The method creates a new
Packet instance with a stanza copy
with swapped source and destination addresses. |
Packet |
Packet.swapStanzaFromTo(StanzaType type)
The method creates a new
Packet instance with a stanza copy
with swapped source and destination addresses and the given type set. |
Packet |
Packet.unpackRouted()
The method unpacks the original packet and stanza from
route
stanza. |
Modifier and Type | Method and Description |
---|---|
abstract Queue<Packet> |
ConnectionManager.processSocketData(IO serv) |
Modifier and Type | Method and Description |
---|---|
static void |
Command.addAction(Packet packet,
Command.Action action)
Method description
|
static void |
Command.addCheckBoxField(Packet packet,
String f_name,
boolean f_value)
Method description
|
static void |
Command.addFieldMultiValue(Packet packet,
String f_name,
List<String> f_value)
A simple method for adding a multi-line (text-multi) data field to the
command data form.
|
static void |
Command.addFieldMultiValue(Packet packet,
String f_name,
Throwable ex) |
static void |
Command.addFieldValue(Packet packet,
String f_name,
String f_value)
Simple method for adding a new field to the command data form.
|
static void |
Command.addFieldValue(Packet packet,
String f_name,
String[] f_values,
String label,
String[] labels,
String[] options)
This method allows to add a new multi-option-select-many data field to the
command data form.
|
static void |
Command.addFieldValue(Packet packet,
String f_name,
String f_value,
String type) |
static void |
Command.addFieldValue(Packet packet,
String f_name,
String f_value,
String type,
String label) |
static void |
Command.addFieldValue(Packet packet,
String f_name,
String f_value,
String label,
String[] labels,
String[] options)
This method allows to add a new multi-option-select-one data field to the
command data form.
|
static void |
Command.addFieldValue(Packet packet,
String f_name,
String f_value,
String label,
String[] labels,
String[] options,
String type) |
static void |
Command.addHiddenField(Packet packet,
String f_name,
String f_value) |
static void |
Command.addInstructions(Packet packet,
String instructions) |
static void |
Command.addNote(Packet packet,
String note) |
protected boolean |
AbstractMessageReceiver.addOutPacket(Packet packet) |
protected boolean |
AbstractMessageReceiver.addOutPacketNB(Packet packet)
Non blocking version of
addOutPacket . |
boolean |
AbstractMessageReceiver.addOutPacketWithTimeout(Packet packet,
ReceiverTimeoutHandler handler,
long delay,
TimeUnit unit)
Method description
|
boolean |
MessageReceiver.addPacket(Packet packet)
Describe
addPacket method here. |
boolean |
AbstractMessageReceiver.addPacket(Packet packet)
Method adds a
Packet object to the internal input queue. |
boolean |
MessageReceiver.addPacketNB(Packet packet) |
boolean |
AbstractMessageReceiver.addPacketNB(Packet packet)
This is a variant of
addPacket(Packet) method which adds
Packet to in the internal input queue without blocking. |
static void |
Command.addTextField(Packet packet,
String f_name,
String f_value) |
static void |
Command.addTitle(Packet packet,
String title) |
Packet |
PacketFilterIfc.filter(Packet packet)
This is the actual packet filtering method.
|
static Command.Action |
Command.getAction(Packet packet) |
static boolean |
Command.getCheckBoxFieldValue(Packet packet,
String f_name) |
static List<Element> |
Command.getData(Packet packet) |
static Element |
Command.getData(Packet packet,
String el_name,
String xmlns) |
static String |
Command.getFieldKeyStartingWith(Packet packet,
String f_name) |
static String |
Command.getFieldValue(Packet packet,
String f_name) |
static String |
Command.getFieldValue(Packet packet,
String f_name,
boolean debug) |
static String[] |
Command.getFieldValues(Packet packet,
String f_name) |
protected String |
ConnectionManager.getServiceId(Packet packet)
Method description
|
protected IO |
ConnectionManager.getXMPPIOService(Packet p)
Method description
|
int |
MessageRouter.hashCodeForPacket(Packet packet) |
int |
AbstractMessageReceiver.hashCodeForPacket(Packet packet)
This method decides how incoming packets are distributed among processing
threads.
|
int |
ConnectionManager.hashCodeForPacket(Packet packet) |
void |
AbstractMessageReceiver.processOutPacket(Packet packet)
By default this method just copies the given packet between queue.
|
void |
MessageRouter.processPacket(Packet packet) |
abstract void |
AbstractMessageReceiver.processPacket(Packet packet)
This is the main
Packet processing method. |
void |
ConnectionManager.processPacket(Packet packet) |
void |
ServerComponent.processPacket(Packet packet,
Queue<Packet> results)
processPacket is a blocking processing method implemented
by all components. |
void |
AbstractMessageReceiver.processPacket(Packet packet,
Queue<Packet> results) |
void |
BasicComponent.processPacket(Packet packet,
Queue<Packet> results) |
void |
MessageRouter.processPacketMR(Packet packet,
Queue<Packet> results)
Method description
|
protected boolean |
BasicComponent.processScriptCommand(Packet pc,
Queue<Packet> results)
Method description
|
abstract boolean |
ConnectionManager.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage)
Processes undelivered packets
|
static boolean |
Command.removeFieldValue(Packet packet,
String f_name) |
void |
ReceiverTimeoutHandler.responseReceived(Packet data,
Packet response) |
static void |
Command.setData(Packet packet,
Element data) |
static void |
Command.setData(Packet packet,
List<Element> data) |
static void |
Command.setStatus(Packet packet,
Command.Status status) |
void |
ReceiverTimeoutHandler.timeOutExpired(Packet data) |
boolean |
ConnectionManager.writePacketToSocket(IO ios,
Packet p)
Method description
|
protected boolean |
ConnectionManager.writePacketToSocket(Packet p) |
protected boolean |
ConnectionManager.writePacketToSocket(Packet p,
String serviceId)
Method description
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractMessageReceiver.addOutPackets(Queue<Packet> packets)
Method description
|
boolean |
MessageReceiver.addPackets(Queue<Packet> packets)
Describe
addPackets method here. |
boolean |
AbstractMessageReceiver.addPackets(Queue<Packet> packets)
This is a convenience method for adding all packets stored in given queue
to the component's internal input queue.
The method calls addPacket(Packet) in a loop for each packet
in the queue. |
void |
ServerComponent.processPacket(Packet packet,
Queue<Packet> results)
processPacket is a blocking processing method implemented
by all components. |
void |
AbstractMessageReceiver.processPacket(Packet packet,
Queue<Packet> results) |
void |
BasicComponent.processPacket(Packet packet,
Queue<Packet> results) |
void |
MessageRouter.processPacketMR(Packet packet,
Queue<Packet> results)
Method description
|
protected boolean |
BasicComponent.processScriptCommand(Packet pc,
Queue<Packet> results)
Method description
|
void |
ConnectionManager.writePacketsToSocket(IO serv,
Queue<Packet> packets) |
Modifier and Type | Method and Description |
---|---|
protected Packet |
ActionAbstract.prepareAmpPacket(Packet packet,
Element rule)
Method description
|
Modifier and Type | Method and Description |
---|---|
boolean |
ActionResultsHandlerIfc.addOutPacket(Packet packet) |
boolean |
AmpComponent.addOutPacket(Packet packet) |
boolean |
ActionIfc.execute(Packet packet,
Element rule) |
boolean |
ConditionIfc.match(Packet packet,
Element rule) |
protected Packet |
ActionAbstract.prepareAmpPacket(Packet packet,
Element rule)
Method description
|
void |
AmpComponent.processPacket(Packet packet) |
protected void |
ActionAbstract.removeTigasePayload(Packet packet)
Method description
|
Modifier and Type | Method and Description |
---|---|
boolean |
ActionResultsHandlerIfc.addOutPackets(Queue<Packet> packets) |
boolean |
AmpComponent.addOutPackets(Queue<Packet> packets) |
Modifier and Type | Method and Description |
---|---|
boolean |
Drop.execute(Packet packet,
Element rule) |
boolean |
Notify.execute(Packet packet,
Element rule) |
boolean |
Store.execute(Packet packet,
Element rule) |
boolean |
Deliver.execute(Packet packet,
Element rule) |
boolean |
Error.execute(Packet packet,
Element rule) |
boolean |
Alert.execute(Packet packet,
Element rule) |
boolean |
Broadcast.preprocess(Packet packet) |
Modifier and Type | Method and Description |
---|---|
boolean |
MatchResource.match(Packet packet,
Element rule) |
boolean |
Deliver.match(Packet packet,
Element rule) |
boolean |
ExpireAt.match(Packet packet,
Element rule) |
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
BoshConnectionManager.processSocketData(XMPPIOService<Object> srv) |
Modifier and Type | Method and Description |
---|---|
boolean |
BoshSessionTaskHandler.addOutStreamClosed(Packet packet,
BoshSession bs,
boolean withTimeout) |
boolean |
BoshConnectionManager.addOutStreamClosed(Packet packet,
BoshSession bs,
boolean withTimeout) |
boolean |
BoshSessionTaskHandler.addOutStreamOpen(Packet packet,
BoshSession bs) |
boolean |
BoshConnectionManager.addOutStreamOpen(Packet packet,
BoshSession bs) |
protected JID |
BoshConnectionManager.changeDataReceiver(Packet packet,
JID newAddress,
String command_sessionId,
XMPPIOService<Object> serv) |
Element |
BoshSessionTaskHandler.getSeeOtherHostError(Packet packet,
BareJID destination) |
Element |
BoshConnectionManager.getSeeOtherHostError(Packet packet,
BareJID destination) |
BareJID |
BoshSessionTaskHandler.getSeeOtherHostForJID(Packet packet,
BareJID userId,
SeeOtherHostIfc.Phase ph) |
BareJID |
BoshConnectionManager.getSeeOtherHostForJID(Packet packet,
BareJID fromJID,
SeeOtherHostIfc.Phase ph) |
void |
BoshSession.init(Packet packet,
BoshIOService service,
long max_wait,
long min_polling,
long max_inactivity,
int concurrent_requests,
int hold_requests,
long max_pause,
int max_batch_size,
long batch_queue_timeout,
Queue<Packet> out_results) |
protected void |
BoshSession.init(Packet packet,
BoshIOService service,
long max_wait,
long min_polling,
long max_inactivity,
int concurrent_requests,
int hold_requests,
long max_pause,
int max_batch_size,
long batch_queue_timeout,
Queue<Packet> out_results,
boolean preBindEnabled)
Method description
|
protected void |
BoshConnectionManager.processCommand(Packet packet) |
void |
BoshConnectionManager.processPacket(Packet packet) |
void |
BoshSession.processPacket(Packet packet,
Queue<Packet> out_results)
Method description
|
void |
BoshSession.processSocketPacket(Packet packet,
BoshIOService service,
Queue<Packet> out_results)
Method description
|
boolean |
BoshSessionTaskHandler.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage) |
void |
BoshIOService.sendErrorAndStop(Authorization errorCode,
StreamError streamError,
Packet packet,
String errorMsg)
Method description
|
protected boolean |
BoshConnectionManager.writePacketToSocket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
protected void |
BoshConnectionManager.addOutPackets(Queue<Packet> out_results,
BoshSession bs)
Method adds packets to the output queue stamping it with the appropriate
BoshSession data |
void |
BoshSession.init(Packet packet,
BoshIOService service,
long max_wait,
long min_polling,
long max_inactivity,
int concurrent_requests,
int hold_requests,
long max_pause,
int max_batch_size,
long batch_queue_timeout,
Queue<Packet> out_results) |
protected void |
BoshSession.init(Packet packet,
BoshIOService service,
long max_wait,
long min_polling,
long max_inactivity,
int concurrent_requests,
int hold_requests,
long max_pause,
int max_batch_size,
long batch_queue_timeout,
Queue<Packet> out_results,
boolean preBindEnabled)
Method description
|
void |
BoshSession.processPacket(Packet packet,
Queue<Packet> out_results)
Method description
|
void |
BoshSession.processSocketPacket(Packet packet,
BoshIOService service,
Queue<Packet> out_results)
Method description
|
boolean |
BoshSession.task(Queue<Packet> out_results,
TimerTask tt)
Method description
|
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
ComponentProtocol.processSocketData(ComponentIOService serv) |
Modifier and Type | Method and Description |
---|---|
void |
CompRepoItem.addCommandFields(Packet packet) |
void |
ComponentProtocolHandler.authenticationFailed(ComponentIOService serv,
Packet packet) |
void |
ComponentProtocol.authenticationFailed(ComponentIOService serv,
Packet packet) |
protected ComponentIOService |
ComponentProtocol.getXMPPIOService(Packet p) |
void |
CompRepoItem.initFromCommand(Packet packet) |
boolean |
ExtProcessor.process(Packet p,
ComponentIOService serv,
ComponentProtocolHandler handler,
Queue<Packet> results) |
boolean |
ComponentProtocol.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage) |
void |
ExtProcessor.startProcessing(Packet p,
ComponentIOService serv,
ComponentProtocolHandler handler,
Queue<Packet> results) |
boolean |
ComponentProtocol.writePacketToSocket(ComponentIOService ios,
Packet p) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExtProcessor.process(Packet p,
ComponentIOService serv,
ComponentProtocolHandler handler,
Queue<Packet> results) |
void |
ExtProcessor.startProcessing(Packet p,
ComponentIOService serv,
ComponentProtocolHandler handler,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
ComponentIOService |
SenderFullJidLB.selectConnection(Packet p,
List<ComponentConnection> conns) |
ComponentIOService |
ReceiverBareJidLB.selectConnection(Packet p,
List<ComponentConnection> conns) |
ComponentIOService |
ReceiverFullJidLB.selectConnection(Packet p,
List<ComponentConnection> conns) |
ComponentIOService |
SenderBareJidLB.selectConnection(Packet p,
List<ComponentConnection> conns) |
ComponentIOService |
LoadBalancerIfc.selectConnection(Packet p,
List<ComponentConnection> conns) |
Modifier and Type | Method and Description |
---|---|
Packet |
PacketCounter.filter(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
PacketCounter.filter(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
MonitorComponent.processPacket(Packet packet)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
MonitorPluginIfc.check10Secs(Queue<Packet> results)
Method description
|
void |
MonitorPluginIfc.check1Day(Queue<Packet> results)
Method description
|
void |
MonitorPluginIfc.check1Hour(Queue<Packet> results)
Method description
|
void |
MonitorPluginIfc.check1Min(Queue<Packet> results)
Method description
|
Modifier and Type | Method and Description |
---|---|
void |
Script.runCommand(Iq packet,
Bindings binds,
Queue<Packet> results) |
void |
CommandIfc.runCommand(Iq packet,
Bindings binds,
Queue<Packet> results) |
void |
AddScriptCommand.runCommand(Iq packet,
Bindings binds,
Queue<Packet> results) |
void |
RemoveScriptCommand.runCommand(Iq packet,
Bindings binds,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
static Packet |
TaskCommons.getMessage(JID from,
JID to,
StanzaType type,
String body) |
static Packet |
TaskCommons.getPresence(JID from,
JID to,
StanzaType type) |
static Packet |
TaskCommons.getPresence(JID from,
JID to,
StanzaType type,
String nick,
String status) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractReceiverTask.addOutPacket(Packet packet)
Method description
|
boolean |
StanzaReceiverIfc.addOutPacket(Packet packet) |
boolean |
StanzaReceiver.addOutPacket(Packet packet) |
protected boolean |
PubSubTestsTask.addOutPacket(Packet packet) |
void |
NewTaskCommand.processCommand(Packet packet,
Packet result,
StanzaReceiver receiv) |
void |
TaskInstanceCommand.processCommand(Packet packet,
Packet result,
StanzaReceiver receiv) |
void |
TaskCommandIfc.processCommand(Packet packet,
Packet result,
StanzaReceiver reciv)
Describe
processCommand method here. |
protected void |
ShortNewsPublisher.processMessage(Packet packet,
Queue<Packet> results) |
protected void |
TesterTask.processMessage(Packet packet,
Queue<Packet> results)
Method description
|
protected void |
AbstractReceiverTask.processMessage(Packet packet,
Queue<Packet> results)
Method description
|
protected void |
PubSubTestsTask.processMessage(Packet packet,
Queue<Packet> results) |
void |
StanzaReceiver.processPacket(Packet packet) |
void |
ReceiverTaskIfc.processPacket(Packet packet,
Queue<Packet> results)
processPacket method takes a packet addressed to this task
as a parameter and does something with the packet. |
void |
AbstractReceiverTask.processPacket(Packet packet,
Queue<Packet> results) |
static void |
TaskCommons.propertyItems2Command(Map<String,PropertyItem> props,
Packet result) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractReceiverTask.addNewSubscribers(Queue<Packet> results,
JID... new_subscr)
Describe
addNewSubscribers method here. |
void |
ShortNewsPublisher.destroy(Queue<Packet> results)
Method description
|
void |
RepoRosterTask.destroy(Queue<Packet> results)
Method description
|
void |
ReceiverTaskIfc.destroy(Queue<Packet> results)
destroy method is called when the task is being permanently
deleted. |
void |
AbstractReceiverTask.destroy(Queue<Packet> results) |
void |
ReceiverTaskIfc.init(Queue<Packet> results)
init method initializes task. |
void |
AbstractReceiverTask.init(Queue<Packet> results) |
protected void |
ShortNewsPublisher.processMessage(Packet packet,
Queue<Packet> results) |
protected void |
TesterTask.processMessage(Packet packet,
Queue<Packet> results)
Method description
|
protected void |
AbstractReceiverTask.processMessage(Packet packet,
Queue<Packet> results)
Method description
|
protected void |
PubSubTestsTask.processMessage(Packet packet,
Queue<Packet> results) |
void |
ReceiverTaskIfc.processPacket(Packet packet,
Queue<Packet> results)
processPacket method takes a packet addressed to this task
as a parameter and does something with the packet. |
void |
AbstractReceiverTask.processPacket(Packet packet,
Queue<Packet> results) |
void |
ReceiverTaskIfc.removeSubscribers(Queue<Packet> results,
JID... subscr)
Method description
|
void |
AbstractReceiverTask.removeSubscribers(Queue<Packet> results,
JID... subscr) |
Modifier and Type | Method and Description |
---|---|
protected void |
SystemMonitorTask.processMessage(Packet packet,
Queue<Packet> results) |
protected void |
SystemMonitorTask.sendPacketOut(Packet input)
Method description
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractMonitor.check10Secs(Queue<Packet> results) |
void |
N270Monitor.check10Secs(Queue<Packet> results) |
void |
ResourceMonitorIfc.check10Secs(Queue<Packet> results) |
void |
CPUMonitor.check10Secs(Queue<Packet> results) |
void |
AbstractMonitor.check1Day(Queue<Packet> results) |
void |
ResourceMonitorIfc.check1Day(Queue<Packet> results) |
void |
DiskMonitor.check1Hour(Queue<Packet> results) |
void |
AbstractMonitor.check1Hour(Queue<Packet> results) |
void |
ResourceMonitorIfc.check1Hour(Queue<Packet> results) |
void |
DiskMonitor.check1Min(Queue<Packet> results) |
void |
AbstractMonitor.check1Min(Queue<Packet> results) |
void |
ResourceMonitorIfc.check1Min(Queue<Packet> results) |
void |
MemMonitor.check1Min(Queue<Packet> results) |
void |
SystemMonitorTask.destroy(Queue<Packet> results) |
void |
SystemMonitorTask.init(Queue<Packet> results) |
void |
AbstractMonitor.prepareCalmDown(String text,
Queue<Packet> results,
Object warning) |
void |
AbstractMonitor.prepareWarning(String text,
Queue<Packet> results,
Object warning) |
protected void |
SystemMonitorTask.processMessage(Packet packet,
Queue<Packet> results) |
protected void |
SystemMonitorTask.sendPacketsOut(Queue<Packet> input)
Method description
|
Modifier and Type | Method and Description |
---|---|
protected Queue<Packet> |
DrupalForumTask.getNewPackets() |
protected Queue<Packet> |
DrupalCommentsTask.getNewPackets() |
Modifier and Type | Method and Description |
---|---|
void |
StanzaHandler.handleStanza(Packet stanza) |
void |
StanzaSender.handleStanza(Packet stanza) |
void |
StanzaSender.processPacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
StanzaHandler.handleStanzas(Queue<Packet> results) |
void |
StanzaSender.handleStanzas(Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
int |
TestComponent.hashCodeForPacket(Packet packet) |
void |
TestComponent.processPacket(Packet packet) |
void |
EchoComponent.processPacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
protected void |
WebSocketXMPPIOService.addReceivedPacket(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
StreamManagementIOProcessor.OutQueue.Entry.getPacketWithStamp() |
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
ClientConnectionManager.processSocketData(XMPPIOService<Object> serv) |
Modifier and Type | Method and Description |
---|---|
void |
StreamManagementIOProcessor.OutQueue.append(Packet packet)
Append packet to waiting for ack queue
|
protected JID |
ClientConnectionManager.changeDataReceiver(Packet packet,
JID newAddress,
String command_sessionId,
XMPPIOService<Object> serv)
Method description
|
protected boolean |
RegistrationThrottlingProcessor.checkLimits(XMPPIOService service,
Packet packet) |
int |
ClientConnectionManager.hashCodeForPacket(Packet packet) |
protected void |
ClientConnectionManager.processCommand(Packet packet)
Method description
|
void |
RegistrationThrottlingProcessor.processCommand(XMPPIOService service,
Packet packet) |
void |
StreamManagementIOProcessor.processCommand(XMPPIOService service,
Packet pc) |
void |
XMPPIOProcessor.processCommand(XMPPIOService service,
Packet packet)
Process command execution which may be sent from other component and
should be processed by processor
|
void |
StreamErrorCounterIOProcessor.processCommand(XMPPIOService service,
Packet packet) |
boolean |
RegistrationThrottlingProcessor.processIncoming(XMPPIOService service,
Packet packet) |
boolean |
StreamManagementIOProcessor.processIncoming(XMPPIOService service,
Packet packet) |
boolean |
XMPPIOProcessor.processIncoming(XMPPIOService service,
Packet packet)
Process packets read from socket as they are sent to SessionManager.
|
boolean |
StreamErrorCounterIOProcessor.processIncoming(XMPPIOService service,
Packet packet) |
boolean |
RegistrationThrottlingProcessor.processOutgoing(XMPPIOService service,
Packet packet) |
boolean |
StreamManagementIOProcessor.processOutgoing(XMPPIOService service,
Packet packet) |
boolean |
XMPPIOProcessor.processOutgoing(XMPPIOService service,
Packet packet)
Process outgoing packets as they are added to XMPPIOService outgoing
packets queue.
|
boolean |
StreamErrorCounterIOProcessor.processOutgoing(XMPPIOService service,
Packet packet) |
void |
ClientConnectionManager.processPacket(Packet packet) |
boolean |
ClientConnectionManager.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage) |
Constructor and Description |
---|
Entry(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
ComponentConnectionManager.processSocketData(XMPPIOService<Object> serv) |
Modifier and Type | Method and Description |
---|---|
protected String |
ComponentConnectionManager.getServiceId(Packet packet) |
void |
ComponentConnectionManager.processPacket(Packet packet) |
boolean |
ComponentConnectionManager.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage) |
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
ServerConnections.getWaitingPackets()
Deprecated.
Method description
|
Queue<Packet> |
S2SConnectionManager.processSocketData(S2SIOService serv) |
Queue<Packet> |
ServerConnectionManager.processSocketData(XMPPIOService<Object> serv)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
S2SConnection.addControlPacket(Packet packet)
Method description
|
void |
ServerConnections.addControlPacket(Packet packet)
Deprecated.
Method description
|
void |
ServerConnections.addDataPacket(Packet packet)
Deprecated.
Method description
|
boolean |
S2SConnectionHandlerIfc.addOutPacket(Packet packet) |
boolean |
ServerConnectionManager.addOutPacket(Packet packet)
Deprecated.
|
boolean |
S2SConnectionManager.addOutPacket(Packet packet) |
int |
ServerConnectionManager.hashCodeForPacket(Packet packet)
Deprecated.
|
int |
S2SConnectionManager.hashCodeForPacket(Packet packet) |
boolean |
S2SProcessor.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
void |
ServerConnectionManager.processDialback(Packet packet,
XMPPIOService<Object> serv)
Deprecated.
Method description
|
void |
ServerConnectionManager.processPacket(Packet packet)
Deprecated.
|
void |
S2SConnectionManager.processPacket(Packet packet) |
boolean |
ServerConnectionManager.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage)
Deprecated.
|
boolean |
S2SConnectionManager.processUndeliveredPacket(Packet packet,
Long stamp,
String errorMessage) |
S2SConnection |
S2SRandomSelector.selectConnection(Packet packet,
Set<S2SConnection> outgoing) |
S2SConnection |
S2SConnectionSelector.selectConnection(Packet packet,
Set<S2SConnection> outgoing) |
boolean |
ServerConnections.sendControlPacket(Packet packet)
Deprecated.
Method description
|
boolean |
CIDConnections.sendControlPacket(String sessionId,
Packet packet)
Method description
|
void |
CIDConnections.sendHandshakingOnly(Packet verify_req)
Method description
|
boolean |
S2SConnection.sendPacket(Packet packet)
Method description
|
boolean |
ServerConnections.sendPacket(Packet packet)
Deprecated.
Describe
sendPacket method here. |
void |
CIDConnections.sendPacket(Packet packet)
Method description
|
boolean |
ServerConnectionManager.sendToIncoming(String session_id,
Packet packet)
Deprecated.
Method description
|
boolean |
S2SConnectionHandlerIfc.writePacketToSocket(IO serv,
Packet packet) |
boolean |
ConnectionHandlerIfc.writePacketToSocket(IO serv,
Packet packet)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
S2SProcessor.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
void |
S2SConnectionHandlerIfc.writePacketsToSocket(IO serv,
Queue<Packet> packets) |
void |
ConnectionHandlerIfc.writePacketsToSocket(IO serv,
Queue<Packet> packets)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
PacketChecker.isAllowed(Packet p,
S2SIOService serv,
CID cid)
Check if incoming packet is allowed on this connection
|
boolean |
PacketChecker.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
S2SAbstractProcessor.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
StreamFeatures.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
StreamError.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
Dialback.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
StartTLS.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
boolean |
PacketChecker.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
S2SAbstractProcessor.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
StreamFeatures.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
StreamError.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
Dialback.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
boolean |
StartTLS.process(Packet p,
S2SIOService serv,
Queue<Packet> results) |
Modifier and Type | Class and Description |
---|---|
protected class |
SessionManager.WriterQueue<E extends Packet> |
Modifier and Type | Field and Description |
---|---|
protected Queue<Packet> |
SessionManager.packetWriterQueue
Field description
|
Modifier and Type | Method and Description |
---|---|
boolean |
SessionManager.addOutPacket(Packet packet) |
protected void |
SessionManager.addOutPackets(Packet packet,
XMPPResourceConnection conn,
Queue<Packet> results) |
boolean |
PacketDefaultHandler.canHandle(Packet packet,
XMPPResourceConnection session)
Method description
|
protected boolean |
SessionManager.fastAddOutPacket(Packet packet) |
boolean |
PacketDefaultHandler.forward(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results)
Method description
|
protected XMPPResourceConnection |
SessionManager.getXMPPResourceConnection(Packet p) |
void |
SessionManager.handleLocalPacket(Packet packet,
XMPPResourceConnection conn) |
int |
SessionManager.hashCodeForPacket(Packet packet) |
protected boolean |
SessionManager.isBrokenPacket(Packet p) |
boolean |
PacketDefaultHandler.preprocess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results)
Method description
|
void |
PacketDefaultHandler.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results)
Method description
|
protected boolean |
SessionManager.processAdminsOrDomains(Packet packet) |
protected boolean |
SessionManager.processCommand(Packet pc) |
void |
SessionManager.processPacket(Packet packet) |
protected void |
SessionManager.processPacket(Packet packet,
XMPPResourceConnection conn) |
protected void |
SessionManager.sendToAdmins(Packet packet) |
Modifier and Type | Method and Description |
---|---|
protected void |
SessionManager.addOutPackets(Packet packet,
XMPPResourceConnection conn,
Queue<Packet> results) |
boolean |
PacketDefaultHandler.forward(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results)
Method description
|
boolean |
PacketDefaultHandler.preprocess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results)
Method description
|
void |
PacketDefaultHandler.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results)
Method description
|
Modifier and Type | Method and Description |
---|---|
void |
StatisticsCollector.processPacket(Packet packet,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
void |
StatisticsCollector.processPacket(Packet packet,
Queue<Packet> results) |
Modifier and Type | Method and Description |
---|---|
Packet |
QueueItem.getPacket() |
Modifier and Type | Method and Description |
---|---|
boolean |
ProcessingThreads.addItem(XMPPProcessorIfc processor,
Packet packet,
XMPPResourceConnection conn)
Method description
|
Constructor and Description |
---|
QueueItem(XMPPProcessorIfc processor,
Packet packet,
XMPPResourceConnection conn)
Constructs ...
|
Modifier and Type | Method and Description |
---|---|
boolean |
TigaseTracer.trace(String ip,
String to_jid,
String from_jid,
String cid,
String id,
String point,
String msg,
Packet packet) |
boolean |
TigaseTracer.traceByCid(String cid,
String point,
String msg,
Packet packet) |
boolean |
TigaseTracer.traceByFromJid(String jid,
String point,
String msg,
Packet packet) |
boolean |
TigaseTracer.traceByToJid(String jid,
String point,
String msg,
Packet packet) |
boolean |
TigaseTracer.tracegByIP(String ip,
String point,
String msg,
Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
VHostItem.addCommandFields(Packet packet) |
void |
VHostItem.initFromCommand(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
Authorization.getResponseMessage(Packet packet,
String text,
boolean includeOriginalXML)
Utility method for generating an error response for a stanza (enclosed by the given
Packet ). |
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
XMPPIOService.getReceivedPackets()
Method description
|
Map<String,Packet> |
XMPPIOService.getWaitingForAct()
Method description
|
Queue<Packet> |
XMPPIOService.getWaitingPackets()
Returns queue with packets waiting to send.
|
Modifier and Type | Method and Description |
---|---|
void |
XMPPIOService.addPacketToSend(Packet packet)
Method
addPacketToSend adds new data which will be processed
during next run. |
protected void |
XMPPIOService.addReceivedPacket(Packet packet)
Method
addReceivedPacket puts processing results to queue. |
Authorization |
XMPPProcessor.canHandle(Packet packet,
XMPPResourceConnection conn) |
Authorization |
XMPPImplIfc.canHandle(Packet packet,
XMPPResourceConnection conn)
By default the method uses
XMPPImplIfc.supElementNamePaths() and
XMPPImplIfc.supTypes() method results to determine whether the plugin would process
given packet. |
void |
XMPPPacketFilterIfc.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
Packet |
Authorization.getResponseMessage(Packet packet,
String text,
boolean includeOriginalXML)
Utility method for generating an error response for a stanza (enclosed by the given
Packet ). |
boolean |
ElementMatcher.matches(Packet packet) |
void |
XMPPPostprocessorIfc.postProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of
packet for which there was no processor. |
boolean |
XMPPPreprocessorIfc.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs pre-processing of
packet . |
void |
XMPPPresenceUpdateProcessorIfc.presenceUpdate(XMPPResourceConnection session,
Packet packet,
Queue<Packet> results) |
void |
XMPPProcessorIfc.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
XMPPProcessorAbstract.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
XMPPProcessorAbstract.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called when a packet is sent from the user, owner of the session
somewhere else to other XMPP entity (other user on the server, other user on a
different server, different server, component, transport, etc....).
|
void |
XMPPProcessorAbstract.processFromUserPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called for all packets sent by the user, owner of this connection/session.
|
abstract void |
XMPPProcessorAbstract.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called when a packet is send from the user who is owner of the session
to the local server (ping, roster management, privacy lists, etc...).
|
void |
XMPPProcessorAbstract.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called for packets received by the server for which no user session
is found - neither sender session or receiver session.
|
abstract void |
XMPPProcessorAbstract.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called when a packet addressed to the server domain is received.
|
void |
XMPPProcessorAbstract.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method is called for all the packets sent TO the user - owner of the session.
|
Modifier and Type | Method and Description |
---|---|
void |
XMPPPacketFilterIfc.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
XMPPPostprocessorIfc.postProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of
packet for which there was no processor. |
boolean |
XMPPPreprocessorIfc.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs pre-processing of
packet . |
void |
XMPPPresenceUpdateProcessorIfc.presenceUpdate(XMPPResourceConnection session,
Packet packet,
Queue<Packet> results) |
void |
XMPPProcessorIfc.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
XMPPProcessorAbstract.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
XMPPProcessorAbstract.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called when a packet is sent from the user, owner of the session
somewhere else to other XMPP entity (other user on the server, other user on a
different server, different server, component, transport, etc....).
|
void |
XMPPProcessorAbstract.processFromUserPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called for all packets sent by the user, owner of this connection/session.
|
abstract void |
XMPPProcessorAbstract.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called when a packet is send from the user who is owner of the session
to the local server (ping, roster management, privacy lists, etc...).
|
void |
XMPPProcessorAbstract.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called for packets received by the server for which no user session
is found - neither sender session or receiver session.
|
abstract void |
XMPPProcessorAbstract.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
The method is called when a packet addressed to the server domain is received.
|
void |
XMPPProcessorAbstract.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method is called for all the packets sent TO the user - owner of the session.
|
void |
XMPPStopListenerIfc.stopped(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Performs additional processing upon closing user session (user either
disconnects or logs-out).
|
Modifier and Type | Method and Description |
---|---|
static Packet |
C2SDeliveryErrorProcessor.makeDeliveryError(Packet packet,
Long stamp)
Creates delivery-error packets to send to session manager to reprocess
undelivered packets
|
static Packet |
PresenceCapabilitiesManager.prepareCapsQuery(JID to,
JID from,
String node)
Method description
|
protected Packet |
JabberIqPrivacy.prepareError(Packet packet,
XMPPResourceConnection session) |
static Packet |
PresenceAbstract.sendPresence(StanzaType t,
JID from,
JID to,
Queue<Packet> results,
Element pres)
Sends Presence stanza from provided parameters as well as returns created
result
Packet object. |
static Packet |
Presence.sendPresence(StanzaType t,
JID from,
JID to,
Queue<Packet> results,
Element pres)
Sends Presence stanza from provided parameters as well as returns created
result
Packet object. |
Modifier and Type | Method and Description |
---|---|
Queue<Packet> |
FlexibleOfflineMessageRetrieval.restorePacketForOffLineUser(List<String> db_ids,
XMPPResourceConnection conn,
MsgRepository repo) |
Queue<Packet> |
OfflineMessages.restorePacketForOffLineUser(XMPPResourceConnection conn,
MsgRepositoryIfc repo)
Method restores all messages from repository for the JID of the current
session.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
JabberIqPrivacy.allowed(Packet packet,
XMPPResourceConnection session) |
protected boolean |
JabberIqPrivacy.allowedByDefault(Packet packet,
XMPPResourceConnection session) |
Authorization |
ServiceDiscovery.canHandle(Packet packet,
XMPPResourceConnection conn) |
Authorization |
JabberIqCommand.canHandle(Packet packet,
XMPPResourceConnection conn) |
Authorization |
FlexibleOfflineMessageRetrieval.canHandle(Packet packet,
XMPPResourceConnection conn) |
Authorization |
JabberIqStats.canHandle(Packet packet,
XMPPResourceConnection conn) |
int |
OfflineMessages.StampComparator.compare(Packet p1,
Packet p2) |
void |
ErrorCounter.ErrorStatisticsHolder.count(Packet packet) |
protected static void |
JabberIqRoster.dynamicGetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
get request related to dynamic roster. |
protected static void |
JabberIqRoster.dynamicSetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
set request related to dynamic roster. |
void |
MessageCarbons.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
JabberIqPrivacy.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MessageAmp.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
ClientStateIndication.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MobileV3.filter(Packet _packet,
XMPPResourceConnection sessionFromSM,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
ErrorCounter.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
Message.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MobileV1.filter(Packet _packet,
XMPPResourceConnection sessionFromSM,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
DomainFilter.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MobileV2.filter(Packet _packet,
XMPPResourceConnection sessionFromSM,
NonAuthUserRepository repo,
Queue<Packet> results) |
static void |
C2SDeliveryErrorProcessor.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
JID toIgnore)
Filters packets created by processors to remove delivery-error payload
|
boolean |
MobileV2.filter(XMPPResourceConnection session,
Packet res,
Map<JID,Packet> queue)
Method description
|
boolean |
MobileV1.filter(XMPPResourceConnection session,
Packet res,
Queue<Packet> queue)
Method description
|
protected static void |
PresenceAbstract.forwardPresence(Queue<Packet> results,
Packet packet,
JID from)
Simply forwards packet to the destination
|
protected static void |
Presence.forwardPresence(Queue<Packet> results,
Packet packet,
JID from)
Simply forwards packet to the destination
|
static Element |
C2SDeliveryErrorProcessor.getDeliveryError(Packet packet)
Finds delivery-error element in packet and returns it
|
protected boolean |
OfflineMessages.isAllowedForOfflineStorage(Packet pac)
Method determines whether packet sent to offline user should be stored in
offline storage or not
|
protected boolean |
OfflineMessages.isAllowedForOfflineStorageDefaults(Packet pac) |
static boolean |
C2SDeliveryErrorProcessor.isDeliveryError(Packet packet)
Checks if packet is delivery-error packet
|
protected boolean |
OfflineMessages.loadOfflineMessages(Packet packet,
XMPPResourceConnection conn)
Method determines whether offline messages should be loaded - the process
should be run only once per user session and only for available/null
presence with priority greater than 0.
|
static Packet |
C2SDeliveryErrorProcessor.makeDeliveryError(Packet packet,
Long stamp)
Creates delivery-error packets to send to session manager to reprocess
undelivered packets
|
protected boolean |
JabberIqPrivacy.matchToPrivacyListElement(boolean packetIn,
Packet packet,
Element elem,
JabberIqPrivacy.ITEM_ACTION action) |
void |
OfflineMessages.postProcess(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository repo,
Queue<Packet> queue,
Map<String,Object> settings)
Performs processing of
packet for which there was no processor. |
void |
MessageAmp.postProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected Packet |
JabberIqPrivacy.prepareError(Packet packet,
XMPPResourceConnection session) |
boolean |
JabberIqPrivacy.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs pre-processing of
packet . |
boolean |
MessageAmp.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
BindResource.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
JabberIqIq.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
Message.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
AbstractAuthPreprocessor.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
StartTLS.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
InvisibleCommand.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
DomainFilter.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
static boolean |
C2SDeliveryErrorProcessor.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings,
Message messageProcessor)
Filters packets before they are processed by processors to filter out delivery-error
packets sent to bare jid if other connection is available
|
void |
MessageCarbons.presenceUpdate(XMPPResourceConnection session,
Packet packet,
Queue<Packet> results) |
protected void |
ErrorCounter.process(Packet packet,
XMPPResourceConnection session) |
void |
SessionBind.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqCommand.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
OfflineMessages.process(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
OfflineMessages processor is triggered by <presence>
stanza. |
void |
MessageCarbons.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqPrivacy.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
MessageAmp.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceSubscription.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of presence packets and calls different methods for particular RosterAbstract.PresenceType |
void |
BindResource.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
CAPS.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
SaslAuth.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqIq.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqAuth.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
ClientStateIndication.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
MessageForwarding.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
StartZLib.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
MobileV3.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
Presence.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of presence packets and calls different methods for particular RosterAbstract.PresenceType |
void |
Message.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
SimpleForwarder.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RosterPresence.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Deprecated.
|
void |
MobileV1.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
StartTLS.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
InvisibleCommand.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
BlockingCommand.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqRegister.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
TODO: Implement registration form configurable and loading all the fields from the registration form TODO: rewrite the plugin using the XMPPProcessorAbstract API |
void |
MessageAll.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqRoster.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of IQ packets with jabber:iq:roster xmlns with the regard whether it's roster set or get request or possibly dynamic-roster is involved. |
void |
LastActivity.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqStats.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceOffline.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceState.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of presence packets and calls different methods for particular RosterAbstract.PresenceType |
void |
MobileV2.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
Jingle.process(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository nonAuthUserRepo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqPrivate.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
static void |
PresenceCapabilitiesManager.processCapsQueryResponse(Packet packet)
Method description
|
protected void |
Presence.processError(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Process presence stanza of type Error.
|
protected void |
PresenceState.processError(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Process presence stanza of type Error.
|
void |
VCardTemp.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqVersion.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
JabberIqVersion.processFromUserPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
LastActivity.processFromUserPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
ServiceDiscovery.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
UrnXmppPing.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RemoteRosterManagement.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqVersion.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
FlexibleOfflineMessageRetrieval.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
BlockingCommand.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
LastActivity.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PepPlugin.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
JabberIqPrivacy.processGetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results) |
protected void |
JabberIqRoster.processGetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
get request. |
protected void |
Presence.processInInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming initial presence (i.e.
|
protected void |
PresenceState.processInInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming initial presence (i.e.
|
protected void |
Presence.processInProbe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming presence probe (i.e.
|
protected void |
PresenceState.processInProbe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming presence probe (i.e.
|
protected void |
PresenceSubscription.processInSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscription request (i.e.
|
protected void |
Presence.processInSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscription request (i.e.
|
protected void |
PresenceSubscription.processInSubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscribed presence (i.e.
|
protected void |
Presence.processInSubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscribed presence (i.e.
|
protected void |
PresenceSubscription.processInUnsubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribe presence (i.e.
|
protected void |
Presence.processInUnsubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribe presence (i.e.
|
protected void |
PresenceSubscription.processInUnsubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribed presence (i.e.
|
protected void |
Presence.processInUnsubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribed presence (i.e.
|
void |
OfflineMessages.processIq(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
ServiceDiscovery.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
UrnXmppPing.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
LastActivity.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PepPlugin.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
Presence.processOutInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType type)
Method is responsible for processing outgoing initial presence (i.e.
|
protected void |
PresenceState.processOutInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType type)
Method is responsible for processing outgoing initial presence (i.e.
|
protected void |
PresenceSubscription.processOutSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing outgoing subscribe and unsubscribe
presence (i.e.
|
protected void |
Presence.processOutSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing outgoing subscribe and unsubscribe
presence (i.e.
|
protected void |
PresenceSubscription.processOutSubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing outgoing subscribed and unsubscribed
presence (i.e.
|
protected void |
Presence.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)
Method description
|
void |
ServiceDiscovery.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
UrnXmppPing.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RemoteRosterManagement.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqVersion.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
FlexibleOfflineMessageRetrieval.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
BlockingCommand.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
LastActivity.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PepPlugin.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
JabberIqPrivacy.processSetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results) |
protected void |
JabberIqRoster.processSetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
set request. |
void |
RemoteRosterManagement.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
LastActivity.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
OfflineMessages.publishInPubSub(Packet packet,
XMPPResourceConnection conn,
Queue<Packet> queue,
Map<String,Object> settings) |
Authorization |
OfflineMessages.savePacketForOffLineUser(Packet pac,
MsgRepositoryIfc repo,
NonAuthUserRepository userRepo)
Method stores messages to offline repository with the following rules
applied, i.e.
|
static void |
PresenceAbstract.updatePresenceChange(Packet presence,
XMPPResourceConnection session,
Queue<Packet> results)
updatePresenceChange method is used to broadcast to all active
resources presence stanza received from other users, like incoming
availability presence, subscription presence and so on... |
static void |
Presence.updatePresenceChange(Packet presence,
XMPPResourceConnection session,
Queue<Packet> results)
updatePresenceChange method is used to broadcast to all active
resources presence stanza received from other users, like incoming
availability presence, subscription presence and so on... |
protected static void |
Presence.updateResourcesAvailable(XMPPResourceConnection session,
StanzaType type,
Packet packet)
Method updates resources information upon receiving initial availability
presence (type available or missing type)
|
Modifier and Type | Method and Description |
---|---|
void |
ClientStateIndication.Logic.activate(XMPPResourceConnection session,
Queue<Packet> results) |
void |
MobileV1.activate(XMPPResourceConnection session,
Queue<Packet> results) |
void |
MobileV2.activate(XMPPResourceConnection session,
Queue<Packet> results) |
protected static void |
Presence.broadcastDirectPresences(StanzaType t,
XMPPResourceConnection session,
Queue<Packet> results,
Element pres)
broadcastDirectPresences broadcast a direct Presence from provided
pres Element object to the collection of JIDs stored in
temporary session data under key DIRECT_PRESENCE . |
protected static void |
PresenceState.broadcastDirectPresences(StanzaType t,
XMPPResourceConnection session,
Queue<Packet> results,
Element pres)
broadcastDirectPresences broadcast a direct Presence from provided
pres Element object to the collection of JIDs stored in
temporary session data under key DIRECT_PRESENCE . |
static void |
Presence.broadcastOffline(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract roster_util)
sendPresenceBroadcast method broadcasts given presence to all
buddies from roster and to all users to which direct presence was sent. |
static void |
PresenceState.broadcastOffline(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract roster_util)
sendPresenceBroadcast method broadcasts given presence to all
buddies from roster and to all users to which direct presence was sent. |
void |
PresenceAbstract.broadcastProbe(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
sendPresenceBroadcast method broadcasts given presence to all
buddies from roster and to all users to which direct presence was sent. |
void |
Presence.broadcastProbe(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
sendPresenceBroadcast method broadcasts given presence to all
buddies from roster and to all users to which direct presence was sent. |
protected void |
Presence.buddyOnline(XMPPResourceConnection session,
JID buddy,
Queue<Packet> results,
boolean online)
Method sends back presence to contact while it becomes online (i.e.
|
protected void |
PresenceState.buddyOnline(XMPPResourceConnection session,
JID buddy,
Queue<Packet> results,
boolean online)
Method sends back presence to contact while it becomes online (i.e.
|
void |
ClientStateIndication.Logic.deactivate(XMPPResourceConnection session,
Queue<Packet> results) |
void |
MobileV1.deactivate(XMPPResourceConnection session,
Queue<Packet> results) |
void |
MobileV2.deactivate(XMPPResourceConnection session,
Queue<Packet> results) |
protected static void |
JabberIqRoster.dynamicGetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
get request related to dynamic roster. |
protected static void |
JabberIqRoster.dynamicSetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
set request related to dynamic roster. |
Element |
Presence.ExtendedPresenceProcessorIfc.extend(XMPPResourceConnection session,
Queue<Packet> results) |
Element |
PresenceState.ExtendedPresenceProcessorIfc.extend(XMPPResourceConnection session,
Queue<Packet> results) |
void |
MessageCarbons.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
JabberIqPrivacy.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MessageAmp.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
ClientStateIndication.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MobileV3.filter(Packet _packet,
XMPPResourceConnection sessionFromSM,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
ErrorCounter.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
Message.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MobileV1.filter(Packet _packet,
XMPPResourceConnection sessionFromSM,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
DomainFilter.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
MobileV2.filter(Packet _packet,
XMPPResourceConnection sessionFromSM,
NonAuthUserRepository repo,
Queue<Packet> results) |
static void |
C2SDeliveryErrorProcessor.filter(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
JID toIgnore)
Filters packets created by processors to remove delivery-error payload
|
boolean |
MobileV2.filter(XMPPResourceConnection session,
Packet res,
Map<JID,Packet> queue)
Method description
|
boolean |
MobileV1.filter(XMPPResourceConnection session,
Packet res,
Queue<Packet> queue)
Method description
|
protected void |
MobileV1.flushQueue(XMPPResourceConnection session,
Queue<Packet> results) |
protected void |
MobileV2.flushQueue(XMPPResourceConnection session,
Queue<Packet> results) |
protected static void |
PresenceAbstract.forwardPresence(Queue<Packet> results,
Packet packet,
JID from)
Simply forwards packet to the destination
|
protected static void |
Presence.forwardPresence(Queue<Packet> results,
Packet packet,
JID from)
Simply forwards packet to the destination
|
static void |
PresenceCapabilitiesManager.handlePresence(JID owner,
JID from,
String[] capsNodes,
Queue<Packet> results)
Method description
|
void |
PresenceCapabilitiesManager.PresenceCapabilitiesListener.handlePresence(JID owner,
JID sender,
String[] capsNodes,
Queue<Packet> results)
Method description
|
void |
OfflineMessages.postProcess(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository repo,
Queue<Packet> queue,
Map<String,Object> settings)
Performs processing of
packet for which there was no processor. |
void |
MessageAmp.postProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
static void |
PresenceCapabilitiesManager.prepareCapsQueries(JID compJid,
JID to,
String[] caps_nodes,
Queue<Packet> results)
Method description
|
boolean |
JabberIqPrivacy.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs pre-processing of
packet . |
boolean |
MessageAmp.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
BindResource.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
JabberIqIq.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
Message.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
AbstractAuthPreprocessor.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
StartTLS.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
InvisibleCommand.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
boolean |
DomainFilter.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
static boolean |
C2SDeliveryErrorProcessor.preProcess(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings,
Message messageProcessor)
Filters packets before they are processed by processors to filter out delivery-error
packets sent to bare jid if other connection is available
|
void |
MessageCarbons.presenceUpdate(XMPPResourceConnection session,
Packet packet,
Queue<Packet> results) |
void |
SessionBind.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqCommand.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
OfflineMessages.process(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
OfflineMessages processor is triggered by <presence>
stanza. |
void |
MessageCarbons.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqPrivacy.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
MessageAmp.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceSubscription.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of presence packets and calls different methods for particular RosterAbstract.PresenceType |
void |
BindResource.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
CAPS.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
SaslAuth.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqIq.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqAuth.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
ClientStateIndication.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
MessageForwarding.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
StartZLib.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
MobileV3.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
Presence.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of presence packets and calls different methods for particular RosterAbstract.PresenceType |
void |
Message.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
SimpleForwarder.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RosterPresence.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Deprecated.
|
void |
MobileV1.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
StartTLS.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
InvisibleCommand.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
BlockingCommand.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqRegister.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
TODO: Implement registration form configurable and loading all the fields from the registration form TODO: rewrite the plugin using the XMPPProcessorAbstract API |
void |
MessageAll.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqRoster.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of IQ packets with jabber:iq:roster xmlns with the regard whether it's roster set or get request or possibly dynamic-roster is involved. |
void |
LastActivity.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqStats.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceOffline.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceState.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Performs processing of presence packets and calls different methods for particular RosterAbstract.PresenceType |
void |
MobileV2.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
Jingle.process(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository nonAuthUserRepo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqPrivate.process(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
Presence.processError(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Process presence stanza of type Error.
|
protected void |
PresenceState.processError(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Process presence stanza of type Error.
|
void |
VCardTemp.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqVersion.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processFromUserOutPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
JabberIqVersion.processFromUserPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
LastActivity.processFromUserPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
ServiceDiscovery.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
UrnXmppPing.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RemoteRosterManagement.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqVersion.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
FlexibleOfflineMessageRetrieval.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
BlockingCommand.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
LastActivity.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PepPlugin.processFromUserToServerPacket(JID connectionId,
Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
JabberIqPrivacy.processGetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results) |
protected void |
JabberIqRoster.processGetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
get request. |
protected void |
Presence.processInInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming initial presence (i.e.
|
protected void |
PresenceState.processInInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming initial presence (i.e.
|
protected void |
Presence.processInProbe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming presence probe (i.e.
|
protected void |
PresenceState.processInProbe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType presenceType)
Method is responsible for processing incoming presence probe (i.e.
|
protected void |
PresenceSubscription.processInSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscription request (i.e.
|
protected void |
Presence.processInSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscription request (i.e.
|
protected void |
PresenceSubscription.processInSubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscribed presence (i.e.
|
protected void |
Presence.processInSubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming subscribed presence (i.e.
|
protected void |
PresenceSubscription.processInUnsubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribe presence (i.e.
|
protected void |
Presence.processInUnsubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribe presence (i.e.
|
protected void |
PresenceSubscription.processInUnsubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribed presence (i.e.
|
protected void |
Presence.processInUnsubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing incoming unsubscribed presence (i.e.
|
void |
OfflineMessages.processIq(Packet packet,
XMPPResourceConnection conn,
NonAuthUserRepository repo,
Queue<Packet> results) |
void |
ServiceDiscovery.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
UrnXmppPing.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
LastActivity.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PepPlugin.processNullSessionPacket(Packet packet,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
Presence.processOutInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType type)
Method is responsible for processing outgoing initial presence (i.e.
|
protected void |
PresenceState.processOutInitial(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType type)
Method is responsible for processing outgoing initial presence (i.e.
|
protected void |
PresenceSubscription.processOutSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing outgoing subscribe and unsubscribe
presence (i.e.
|
protected void |
Presence.processOutSubscribe(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing outgoing subscribe and unsubscribe
presence (i.e.
|
protected void |
PresenceSubscription.processOutSubscribed(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings,
RosterAbstract.PresenceType pres_type)
Method is responsible for processing outgoing subscribed and unsubscribed
presence (i.e.
|
protected void |
Presence.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)
Method description
|
void |
ServiceDiscovery.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
UrnXmppPing.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RemoteRosterManagement.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
JabberIqVersion.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
FlexibleOfflineMessageRetrieval.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
BlockingCommand.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
LastActivity.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PepPlugin.processServerSessionPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
protected void |
JabberIqPrivacy.processSetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results) |
protected void |
JabberIqRoster.processSetRequest(Packet packet,
XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Method processes roster
set request. |
void |
RemoteRosterManagement.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCardTemp.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
EntityTime.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
VCard4.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings)
Method description
|
void |
LastActivity.processToUserPacket(Packet packet,
XMPPResourceConnection session,
NonAuthUserRepository repo,
Queue<Packet> results,
Map<String,Object> settings) |
void |
OfflineMessages.publishInPubSub(Packet packet,
XMPPResourceConnection conn,
Queue<Packet> queue,
Map<String,Object> settings) |
static void |
Presence.rebroadcastPresence(XMPPResourceConnection session,
Queue<Packet> results) |
static void |
PresenceState.rebroadcastPresence(XMPPResourceConnection session,
Queue<Packet> results) |
void |
Presence.resendPendingInRequests(XMPPResourceConnection session,
Queue<Packet> results)
Sends out all pending subscription request during user log-in.
|
void |
PresenceState.resendPendingInRequests(XMPPResourceConnection session,
Queue<Packet> results)
Sends out all pending subscription request during user log-in.
|
static void |
PresenceAbstract.sendPresence(StanzaType t,
BareJID from,
BareJID to,
Queue<Packet> results,
Element pres)
Sends Presence stanza from provided parameters without returning created
result
Packet object. |
static void |
Presence.sendPresence(StanzaType t,
BareJID from,
BareJID to,
Queue<Packet> results,
Element pres)
Sends Presence stanza from provided parameters without returning created
result
Packet object. |
static Packet |
PresenceAbstract.sendPresence(StanzaType t,
JID from,
JID to,
Queue<Packet> results,
Element pres)
Sends Presence stanza from provided parameters as well as returns created
result
Packet object. |
static Packet |
Presence.sendPresence(StanzaType t,
JID from,
JID to,
Queue<Packet> results,
Element pres)
Sends Presence stanza from provided parameters as well as returns created
result
Packet object. |
static void |
Presence.sendPresenceBroadcast(StanzaType t,
XMPPResourceConnection session,
EnumSet<RosterAbstract.SubscriptionType> subscrs,
Queue<Packet> results,
Element pres,
Map<String,Object> settings,
RosterAbstract roster_util)
sendPresenceBroadcast method broadcasts given presence to all
buddies from roster and to all users to which direct presence was sent. |
static void |
PresenceState.sendPresenceBroadcast(StanzaType t,
XMPPResourceConnection session,
EnumSet<RosterAbstract.SubscriptionType> subscrs,
Queue<Packet> results,
Element pres,
Map<String,Object> settings,
RosterAbstract roster_util)
sendPresenceBroadcast method broadcasts given presence to all
buddies from roster and to all users to which direct presence was sent. |
protected void |
Presence.sendRosterOfflinePresence(XMPPResourceConnection session,
Queue<Packet> results)
Method sends server generated presence unavailable for all buddies from the
roster with a custom status message.
|
protected void |
PresenceState.sendRosterOfflinePresence(XMPPResourceConnection session,
Queue<Packet> results)
Method sends server generated presence unavailable for all buddies from the
roster with a custom status message.
|
void |
Presence.stopped(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings) |
void |
RosterPresence.stopped(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings)
Deprecated.
|
void |
LastActivity.stopped(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceOffline.stopped(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings) |
void |
PresenceState.stopped(XMPPResourceConnection session,
Queue<Packet> results,
Map<String,Object> settings) |
static void |
RemoteRosterManagement.updateBuddyChange(XMPPResourceConnection session,
Element item,
Element update,
Queue<Packet> results)
Method description
|
protected static void |
Presence.updateOfflineChange(XMPPResourceConnection session,
Queue<Packet> results)
updateOfflineChange method broadcast off-line presence to all
other user active resources. |
protected static void |
PresenceState.updateOfflineChange(XMPPResourceConnection session,
Queue<Packet> results)
updateOfflineChange method broadcast off-line presence to all
other user active resources. |
static void |
PresenceAbstract.updatePresenceChange(Packet presence,
XMPPResourceConnection session,
Queue<Packet> results)
updatePresenceChange method is used to broadcast to all active
resources presence stanza received from other users, like incoming
availability presence, subscription presence and so on... |
static void |
Presence.updatePresenceChange(Packet presence,
XMPPResourceConnection session,
Queue<Packet> results)
updatePresenceChange method is used to broadcast to all active
resources presence stanza received from other users, like incoming
availability presence, subscription presence and so on... |
static void |
PresenceAbstract.updateUserResources(Element presence,
XMPPResourceConnection session,
Queue<Packet> results,
boolean initial)
updateUserResources method is used to broadcast to all
other resources presence stanza from one user resource. |
static void |
Presence.updateUserResources(Element presence,
XMPPResourceConnection session,
Queue<Packet> results,
boolean initial)
updateUserResources method is used to broadcast to all
other resources presence stanza from one user resource. |
Modifier and Type | Method and Description |
---|---|
RosterAbstract.PresenceType |
RosterAbstract.getPresenceType(XMPPResourceConnection session,
Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
RosterAbstract.updateBuddyChange(XMPPResourceConnection session,
Queue<Packet> results,
Element item) |
Copyright © 2019 "Tigase, Inc.". All rights reserved.