Package org.jivesoftware.openfire.http

Class HttpSession

java.lang.Object
org.jivesoftware.openfire.session.LocalSession
org.jivesoftware.openfire.session.LocalClientSession
org.jivesoftware.openfire.http.HttpSession
All Implemented Interfaces:
ChannelHandler<org.xmpp.packet.Packet>, RoutableChannelHandler, ClientSession, Session
public class HttpSession extends LocalClientSession
A session represents a series of interactions with an XMPP client sending packets using the HTTP Binding protocol specified in XEP-0124. A session can have several client connections open simultaneously while awaiting packets bound for the client from the server.
Author:
Alexander Wenckus

  • Field Details

    • IGNORE_INVALID_PAUSE

      public static SystemProperty<Boolean> IGNORE_INVALID_PAUSE
      ` Controls if client-provided 'pause' values that are invalid (higher than 'maxpause') are ignored or will cause the client to be disconnected.

  • Constructor Details

  • Method Details

    • getAvailableStreamFeatures

      public List<org.dom4j.Element> getAvailableStreamFeatures()
      Returns the stream features which are available for this session.
      Overrides:
      getAvailableStreamFeatures in class LocalClientSession
      Returns:
      the stream features which are available for this session.

    • getWait

      public Duration getWait()
      Specifies the longest time (in seconds) that the connection manager is allowed to wait before responding to any request during the session. This enables the client to prevent its TCP connection from expiring due to inactivity, as well as to limit the delay before it discovers any network failure.
      Returns:
      the longest time it is permissible to wait for a response.

    • getHold

      public int getHold()
      Specifies the maximum number of requests the connection manager is allowed to keep waiting at any one time during the session. (For example, if a constrained client is unable to keep open more than two HTTP connections to the same HTTP server simultaneously, then it SHOULD specify a value of "1".)
      Returns:
      the maximum number of simultaneous waiting requests

    • getMaxPollingInterval

      public Duration getMaxPollingInterval()
      Returns the max interval within which a client can send polling requests. If more than one request occurs in the interval the session will be terminated.
      Returns:
      the max interval within which a client can send polling requests. If more than one request occurs in the interval the session will be terminated.

    • getMaxRequests

      public int getMaxRequests()
      Returns the max number of requests it is permissible for this session to have open at any one time.
      Returns:
      the max number of requests it is permissible for this session to have open at any one time.

    • getMaxPause

      public Duration getMaxPause()
      Returns the maximum length of a temporary session pause that the client MAY request.
      Returns:
      the maximum length of a temporary session pause that the client MAY request.

    • isEncrypted

      public boolean isEncrypted()
      Returns true if all connections on this session should be encrypted, and false if they should not.
      Specified by:
      isEncrypted in interface Session
      Overrides:
      isEncrypted in class LocalSession
      Returns:
      true if all connections on this session should be encrypted, and false if they should not.

    • isPollingSession

      public boolean isPollingSession()
      Returns true if this session is a polling session. Some clients may be restricted to open only one connection to the server. In this case the client SHOULD inform the server by setting the values of the 'wait' and/or 'hold' attributes in its session creation request to "0", and then "poll" the server at regular intervals throughout the session for stanzas it may have received from the server.
      Returns:
      true if this session is a polling session.

    • setInactivityTimeout

      public void setInactivityTimeout(Duration inactivityTimeout)
      Sets the time, in seconds, after which this session will be considered inactive and be terminated.
      Parameters:
      inactivityTimeout - the time, in seconds, after which this session will be considered inactive and be terminated.

    • resetInactivityTimeout

      public void resetInactivityTimeout()
      Resets the inactivity timeout of this session to default. A session's inactivity timeout can be temporarily changed using session pause requests.
      See Also:

    • getInactivityTimeout

      public Duration getInactivityTimeout()
      Returns the time, in seconds, after which this session will be considered inactive and terminated.
      Returns:
      the time, in seconds, after which this session will be considered inactive and terminated.

    • pause

      public void pause(Duration duration)
      Pauses the session for the given amount of time. If a client encounters an exceptional temporary situation during which it will be unable to send requests to the connection manager for a period of time greater than the maximum inactivity period, then the client MAY request a temporary increase to the maximum inactivity period by including a 'pause' attribute in a request.
      Parameters:
      duration - the time, in seconds, after which this session will be considered inactive and terminated.

    • getLastActivity

      public Instant getLastActivity()
      Returns the time in milliseconds since the epoch that this session was last active. Activity is a request was either made or responded to. If the session is currently active, meaning there are connections awaiting a response, the current time is returned.
      Returns:
      the time in milliseconds since the epoch that this session was last active.

    • getLastAcknowledged

      public long getLastAcknowledged()
      Returns the highest 'rid' attribute the server has received where it has also received all requests with lower 'rid' values. When responding to a request that it has been holding, if the server finds it has already received another request with a higher 'rid' attribute (typically while it was holding the first request), then it MAY acknowledge the reception to the client.
      Returns:
      the highest 'rid' attribute the server has received where it has also received all requests with lower 'rid' values.

    • getMajorVersion

      public int getMajorVersion()
      Returns the major version of BOSH which this session utilizes. The version refers to the version of the XEP which the connecting client implements. If the client did not specify a version 1 is returned as 1.5 is the last version of the XEP that the client was not required to pass along its version information when creating a session.
      Returns:
      the major version of the BOSH XEP which the client is utilizing.

    • getMinorVersion

      public int getMinorVersion()
      Returns the major version of BOSH which this session utilizes. The version refers to the version of the XEP which the connecting client implements. If the client did not specify a version 5 is returned as 1.5 is the last version of the XEP that the client was not required to pass along its version information when creating a session.
      Returns:
      the minor version of the BOSH XEP which the client is utilizing.

    • setLastResponseEmpty

      public void setLastResponseEmpty(boolean lastResponseEmpty)
      lastResponseEmpty true if last response of this session is an empty body element. This is used in overactivity checking.
      Parameters:
      lastResponseEmpty - true if last response of this session is an empty body element.

    • forwardRequest

      public void forwardRequest(HttpBindBody body, javax.servlet.AsyncContext context) throws HttpBindException, HttpConnectionClosedException, IOException
      Forwards a client request, which is related to a session, to the server. A connection is created and queued up in the provided session. When a connection reaches the top of a queue any pending packets bound for the client will be forwarded to the client through the connection.
      Parameters:
      body - the body element that was sent containing the request for a new session.
      context - the context of the asynchronous servlet call leading up to this method call.
      Throws:
      HttpBindException - for several reasons: if the encoding inside an auth packet is not recognized by the server, or if the packet type is not recognized.
      HttpConnectionClosedException - if the session is no longer available.
      IOException - if an input or output exception occurred

    • sendPendingPackets

      protected void sendPendingPackets(List<org.dom4j.Element> packetsToSend)
      This method sends any pending packets in the session. If no packets are pending, this method simply returns. The method is internally synchronized to avoid simultaneous sending operations on this Session. If two threads try to run this method simultaneously, the first one will trigger the pending packets to be sent, while the second one will simply return (as there are no packets left to send).

    • getPeerCertificates

      public X509Certificate[] getPeerCertificates()
      Return the X509Certificates associated with this session.
      Specified by:
      getPeerCertificates in interface Session
      Overrides:
      getPeerCertificates in class LocalSession
      Returns:
      the X509Certificate associated with this session.

    • close

      public void close()
      Description copied from interface: Session
      Close this session, including associated (socket) connection(s) where appropriate. The order of events for closing the session is:
      • Set closing flag to prevent redundant shutdowns.
      • Call notifyEvent all listeners that the channel is shutting down.
      • Close the underlying connection(s) (eg: socket).
      Implementations should ensure that after invocation, the result of Session.getStatus() will be CLOSED.
      Specified by:
      close in interface Session
      Overrides:
      close in class LocalSession

    • deliver

      public void deliver(@Nonnull org.xmpp.packet.Packet stanza)
      Overrides:
      deliver in class LocalClientSession

    • createEmptyBody

      @Nonnull protected String createEmptyBody(boolean terminate)
      Creates an empty BOSH 'body' element, optionally including a 'terminate' type attribute (that, in BOSH, signifies the end of a session). The element will include an 'ack' attribute, of which the value is the highest request ID (rid) the server has received where it has also received all requests with lower request ID values.
      Parameters:
      terminate - Whether to include a type attribute with value 'terminate'.
      Returns:
      The string representation of an empty BOSH 'body' element.

    • createTerminalBindingBody

      @Nonnull protected String createTerminalBindingBody(@Nonnull String condition)
      Creates an empty BOSH 'body' element that including a 'terminate' type attribute (that, in BOSH, signifies the end of a session), and sets the 'condition' attribute to a specified value.
      Parameters:
      condition - The terminate condition to set.
      Returns:
      The string representation of a BOSH 'body' element.

    • createRemoteStreamErrorBody

      @Nonnull protected String createRemoteStreamErrorBody(@Nonnull org.xmpp.packet.StreamError error)
      Creates an empty BOSH 'body' element that including a 'terminate' type attribute (that, in BOSH, signifies the end of a session), sets the 'condition' attribute to 'remote-stream-error' (to signal that an XMPP error is transported), and includes the error in the body.
      Parameters:
      error - The error to be included in the body.
      Returns:
      The string representation of a BOSH 'body' element.

    • toString

      public String toString()
      Overrides:
      toString in class LocalClientSession