Class ServerStanzaHandler
- java.lang.Object
-
- org.jivesoftware.openfire.net.StanzaHandler
-
- org.jivesoftware.openfire.net.ServerStanzaHandler
-
public class ServerStanzaHandler extends StanzaHandler
Handler of XML stanzas sent by remote servers. Remote servers that send stanzas with no TO or FROM will get their connections closed. Moreover, remote servers that try to send stanzas from a not validated domain will also get their connections closed.Server-to-server communication requires two TCP connections between the servers where one is used for sending packets whilst the other connection is used for receiving packets. The connection used for receiving packets will use a ServerStanzaHandler since the other connection will not receive packets.
- Author:
- Gaston Dombiak, Alex Gidman, Matthew Vivian
-
-
Field Summary
Fields Modifier and Type Field Description static SystemProperty<Boolean>SKIP_JID_VALIDATIONControls if JIDs that are in the addresses of stanzas supplied by remote domains are validated.-
Fields inherited from class org.jivesoftware.openfire.net.StanzaHandler
connection, PROPERTY_OVERWRITE_EMPTY_TO, router, saslStatus, session, sessionCreated, startedSASL, startedTLS, waitingCompressionACK
-
-
Constructor Summary
Constructors Constructor Description ServerStanzaHandler(PacketRouter router, Connection connection, boolean directTLS)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidcreateSession(org.xmlpull.v1.XmlPullParser xpp)Uses the XPP to grab the opening stream tag and create an active session object.protected org.dom4j.DocumentgetStreamHeader()protected voidprocessIQ(org.xmpp.packet.IQ packet)Process the received IQ packet.protected voidprocessMessage(org.xmpp.packet.Message packet)Process the received Message packet.protected voidprocessPresence(org.xmpp.packet.Presence packet)Process the received Presence packet.protected voidtlsNegotiated(org.xmlpull.v1.XmlPullParser xpp)TLS negotiation was successful so open a new stream and offer the new stream features.-
Methods inherited from class org.jivesoftware.openfire.net.StanzaHandler
closeNeverEncryptedConnection, closeNeverSecuredConnection, compressClient, compressionSuccessful, getAddress, initiateSession, isEndOfStream, isHostUnknown, isStartOfStream, isStreamManagementStanza, negotiateTLS, process, processStanza, saslSuccessful, setSession
-
-
-
-
Field Detail
-
SKIP_JID_VALIDATION
public static final SystemProperty<Boolean> SKIP_JID_VALIDATION
Controls if JIDs that are in the addresses of stanzas supplied by remote domains are validated.
-
-
Constructor Detail
-
ServerStanzaHandler
public ServerStanzaHandler(PacketRouter router, Connection connection, boolean directTLS)
-
-
Method Detail
-
createSession
protected void createSession(org.xmlpull.v1.XmlPullParser xpp) throws org.xmlpull.v1.XmlPullParserException, IOExceptionDescription copied from class:StanzaHandlerUses the XPP to grab the opening stream tag and create an active session object. The session to create will depend on the sent namespace. In all cases, the method obtains the opening stream tag, checks for errors, and either creates a session or returns an error and kills the connection. If the connection remains open, the XPP will be set to be ready for the first packet. A call to next() should result in an START_TAG state with the first packet in the stream.- Overrides:
createSessionin classStanzaHandler- Parameters:
xpp- the pull parser- Throws:
org.xmlpull.v1.XmlPullParserException- if an exception occurs reading from the pull parserIOException- if an IO exception occurs reading from the pull parser
-
getStreamHeader
protected org.dom4j.Document getStreamHeader()
- Overrides:
getStreamHeaderin classStanzaHandler
-
tlsNegotiated
protected void tlsNegotiated(org.xmlpull.v1.XmlPullParser xpp) throws org.xmlpull.v1.XmlPullParserException, IOExceptionDescription copied from class:StanzaHandlerTLS negotiation was successful so open a new stream and offer the new stream features. The new stream features will include available SASL mechanisms and specific features depending on the session type such as auth for Non-SASL authentication and register for in-band registration.- Overrides:
tlsNegotiatedin classStanzaHandler- Throws:
org.xmlpull.v1.XmlPullParserExceptionIOException
-
processIQ
protected void processIQ(org.xmpp.packet.IQ packet) throws UnauthorizedExceptionDescription copied from class:StanzaHandlerProcess the received IQ packet. RegisteredPacketInterceptorwill be invoked before and after the packet was routed.Subclasses may redefine this method for different reasons such as modifying the sender of the packet to avoid spoofing, rejecting the packet or even process the packet in another thread.
- Overrides:
processIQin classStanzaHandler- Parameters:
packet- the received packet.- Throws:
UnauthorizedException- if service is not available to sender.
-
processPresence
protected void processPresence(org.xmpp.packet.Presence packet) throws UnauthorizedExceptionDescription copied from class:StanzaHandlerProcess the received Presence packet. RegisteredPacketInterceptorwill be invoked before and after the packet was routed.Subclasses may redefine this method for different reasons such as modifying the sender of the packet to avoid spoofing, rejecting the packet or even process the packet in another thread.
- Overrides:
processPresencein classStanzaHandler- Parameters:
packet- the received packet.- Throws:
UnauthorizedException- if service is not available to sender.
-
processMessage
protected void processMessage(org.xmpp.packet.Message packet) throws UnauthorizedExceptionDescription copied from class:StanzaHandlerProcess the received Message packet. RegisteredPacketInterceptorwill be invoked before and after the packet was routed.Subclasses may redefine this method for different reasons such as modifying the sender of the packet to avoid spoofing, rejecting the packet or even process the packet in another thread.
- Overrides:
processMessagein classStanzaHandler- Parameters:
packet- the received packet.- Throws:
UnauthorizedException- if service is not available to sender.
-
-