Class ServerSessionImpl

java.lang.Object
org.cometd.server.ServerSessionImpl
All Implemented Interfaces:
ServerSession, Session, org.eclipse.jetty.util.component.Dumpable
public class ServerSessionImpl extends Object implements ServerSession, org.eclipse.jetty.util.component.Dumpable

  • Constructor Details

  • Method Details

    • getBayeuxServer

      public BayeuxServerImpl getBayeuxServer()

    • getUserAgent

      public String getUserAgent()
      Specified by:
      getUserAgent in interface ServerSession
      Returns:
      the remote user agent

    • setUserAgent

      public void setUserAgent(String userAgent)
      Parameters:
      userAgent - the remote user agent

    • getBrowserId

      public String getBrowserId()
      Returns:
      the remote client identifier

    • setBrowserId

      public void setBrowserId(String browserId)

      Sets a remote client identifier, typically a browser.

      Parameters:
      browserId - the remote client identifier

    • sweep

      protected boolean sweep(long now)

    • getSubscriptions

      public Set<ServerChannel> getSubscriptions()
      Specified by:
      getSubscriptions in interface ServerSession
      Returns:
      the set of channels to which this session is subscribed to

    • addExtension

      public void addExtension(ServerSession.Extension extension)
      Description copied from interface: ServerSession

      Adds the given extension to this session.

      Specified by:
      addExtension in interface ServerSession
      Parameters:
      extension - the extension to add
      See Also:

    • removeExtension

      public void removeExtension(ServerSession.Extension extension)
      Description copied from interface: ServerSession

      Removes the given extension from this session.

      Specified by:
      removeExtension in interface ServerSession
      Parameters:
      extension - the extension to remove
      See Also:

    • getExtensions

      public List<ServerSession.Extension> getExtensions()
      Specified by:
      getExtensions in interface ServerSession
      Returns:
      an immutable list of extensions present in this ServerSession instance
      See Also:

    • batch

      public void batch(Runnable batch)
      Description copied from interface: Session

      Executes the given command in a batch so that any Bayeux message sent by the command (via the Bayeux API) is queued up until the end of the command and then all messages are sent at once.

      Specified by:
      batch in interface Session
      Parameters:
      batch - the Runnable to run as a batch

    • deliver

      public void deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise)
      Description copied from interface: ServerSession

      Delivers the given message to this session.

      This is different from ServerChannel.publish(Session, ServerMessage.Mutable, Promise) as the message is delivered only to this session and not to all subscribers of the channel.

      The message should still have a channel id specified, so that the ClientSession may identify the listeners the message should be delivered to.

      Specified by:
      deliver in interface ServerSession
      Parameters:
      sender - the session delivering the message
      message - the message to deliver
      promise - the promise to notify with the result of the deliver
      See Also:

    • deliver

      public void deliver(Session sender, String channelId, Object data, Promise<Boolean> promise)
      Description copied from interface: ServerSession

      Delivers the given information to this session.

      Specified by:
      deliver in interface ServerSession
      Parameters:
      sender - the session delivering the message
      channelId - the channel of the message
      data - the data of the message
      promise - the promise to notify with the result of the deliver
      See Also:

    • deliver1

      protected void deliver1(ServerSession sender, ServerMessage.Mutable mutable, Promise<Boolean> promise)

    • extendOutgoing

      protected void extendOutgoing(ServerSession sender, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)

    • handshake

      public boolean handshake(ServerMessage.Mutable message)

    • connected

      public boolean connected()

    • disconnect

      public void disconnect()
      Description copied from interface: Session
      Disconnects this session, ending the link between the client and the server peers.
      Specified by:
      disconnect in interface Session
      See Also:

    • startBatch

      public void startBatch()
      Description copied from interface: Session

      Starts a batch, to be ended with Session.endBatch().

      The Session.batch(Runnable) method should be preferred since it automatically starts and ends a batch without relying on a try/finally block.

      This method is to be used in the cases where the use of Session.batch(Runnable) is not possible or would make the code more complex.

      Specified by:
      startBatch in interface Session
      See Also:

    • endBatch

      public boolean endBatch()
      Description copied from interface: Session

      Ends a batch started with Session.startBatch().

      Specified by:
      endBatch in interface Session
      Returns:
      true if the batch ended and there were messages to send.
      See Also:

    • getLocalSession

      public LocalSession getLocalSession()
      Specified by:
      getLocalSession in interface ServerSession
      Returns:
      the LocalSession associated with this session, or null if this is a session representing a remote client.

    • isLocalSession

      public boolean isLocalSession()
      Specified by:
      isLocalSession in interface ServerSession
      Returns:
      whether this is a session for a local client on server-side

    • addListener

      public void addListener(ServerSession.ServerSessionListener listener)
      Description copied from interface: ServerSession

      Adds the given listener to this session.

      Specified by:
      addListener in interface ServerSession
      Parameters:
      listener - the listener to add
      See Also:

    • getId

      public String getId()
      Description copied from interface: Session

      The clientId of the session.

      This would more correctly be called a "sessionId", but for backwards compatibility with the Bayeux protocol, it is a field called "clientId" that identifies a session.

      Specified by:
      getId in interface Session
      Returns:
      the id of this session

    • getLock

      public Lock getLock()

    • getQueue

      public Queue<ServerMessage> getQueue()

    • hasNonLazyMessages

      public boolean hasNonLazyMessages()

    • addMessage

      protected void addMessage(ServerMessage message)

    • takeQueue

      public List<ServerMessage> takeQueue(List<ServerMessage.Mutable> replies)

    • notifySuspended

      public void notifySuspended(ServerMessage message, long timeout)

    • notifyResumed

      public void notifyResumed(ServerMessage message, boolean timeout)

    • removeListener

      public void removeListener(ServerSession.ServerSessionListener listener)
      Description copied from interface: ServerSession

      Removes the given listener from this session.

      Specified by:
      removeListener in interface ServerSession
      Parameters:
      listener - the listener to remove
      See Also:

    • getListeners

      public List<ServerSession.ServerSessionListener> getListeners()

    • setScheduler

      public void setScheduler(AbstractServerTransport.Scheduler newScheduler)

    • shouldSchedule

      public boolean shouldSchedule()

    • flush

      public void flush()

    • destroyScheduler

      public void destroyScheduler()

    • cancelExpiration

      public void cancelExpiration(boolean metaConnect)

    • scheduleExpiration

      public void scheduleExpiration(long defaultInterval, long defaultMaxInterval, long metaConnectCycle)

    • getMetaConnectCycle

      public long getMetaConnectCycle()

    • getMaxInterval

      public long getMaxInterval()
      Specified by:
      getMaxInterval in interface ServerSession
      Returns:
      the max period of time, in milliseconds, that the server waits before expiring the session when the client does not send messages to the server, or -1 if the default value is used

    • setMaxInterval

      public void setMaxInterval(long maxInterval)
      Specified by:
      setMaxInterval in interface ServerSession
      Parameters:
      maxInterval - the max period of time, in milliseconds, that the server waits before expiring the session

    • getIntervalNanoTime

      public long getIntervalNanoTime()
      Returns:
      the nanoTime at which this session is expired

    • getAttribute

      public Object getAttribute(String name)
      Description copied from interface: Session

      Retrieves the value of named session attribute.

      Specified by:
      getAttribute in interface Session
      Parameters:
      name - the name of the attribute
      Returns:
      the attribute value or null if the attribute is not present

    • getAttributeNames

      public Set<String> getAttributeNames()
      Specified by:
      getAttributeNames in interface Session
      Returns:
      the session attribute names.

    • removeAttribute

      public Object removeAttribute(String name)
      Description copied from interface: Session

      Removes a named session attribute.

      Specified by:
      removeAttribute in interface Session
      Parameters:
      name - the name of the attribute
      Returns:
      the value of the attribute

    • setAttribute

      public void setAttribute(String name, Object value)
      Description copied from interface: Session

      Sets a named session attribute value.

      Session attributes are convenience data that allows arbitrary application data to be associated with a session.

      Specified by:
      setAttribute in interface Session
      Parameters:
      name - the attribute name
      value - the attribute value

    • isHandshook

      public boolean isHandshook()
      Description copied from interface: Session

      A handshook session is a session where the handshake has successfully completed

      Specified by:
      isHandshook in interface Session
      Returns:
      whether the session is handshook

    • isConnected

      public boolean isConnected()
      Description copied from interface: Session

      A connected session is a session where the link between the client and the server has been established.

      Specified by:
      isConnected in interface Session
      Returns:
      whether the session is connected
      See Also:

    • isDisconnected

      public boolean isDisconnected()

    • isTerminated

      public boolean isTerminated()

    • extendIncoming

      protected void extendIncoming(ServerMessage.Mutable message, Promise<Boolean> promise)

    • reAdvise

      public void reAdvise()

    • takeAdvice

      public Map<String,Object> takeAdvice(ServerTransport transport)

    • getServerTransport

      public ServerTransport getServerTransport()
      Specified by:
      getServerTransport in interface ServerSession
      Returns:
      the ServerTransport associated with this session

    • setServerTransport

      public void setServerTransport(ServerTransport transport)

    • updateServerEndPoint

      public boolean updateServerEndPoint(Object newEndPoint)

    • getTimeout

      public long getTimeout()
      Specified by:
      getTimeout in interface ServerSession
      Returns:
      the period of time, in milliseconds, that the server will hold connect messages for this session or -1 if the default value is used
      See Also:

    • getInterval

      public long getInterval()
      Specified by:
      getInterval in interface ServerSession
      Returns:
      the period of time, in milliseconds, that the client associated with this session will wait before issuing a connect message, or -1 if the default value is used
      See Also:

    • setTimeout

      public void setTimeout(long timeoutMS)
      Specified by:
      setTimeout in interface ServerSession
      Parameters:
      timeoutMS - the period of time, in milliseconds, that the server will hold connect messages for this session

    • setInterval

      public void setInterval(long intervalMS)
      Specified by:
      setInterval in interface ServerSession
      Parameters:
      intervalMS - the period of time, in milliseconds, that the client associated with this session will wait before issuing a connect message

    • isBroadcastToPublisher

      public boolean isBroadcastToPublisher()
      Specified by:
      isBroadcastToPublisher in interface ServerSession
      Returns:
      whether this session sends messages back to itself

    • setBroadcastToPublisher

      public void setBroadcastToPublisher(boolean value)
      Description copied from interface: ServerSession
      Sets whether this session sends messages back to itself.
      Specified by:
      setBroadcastToPublisher in interface ServerSession
      Parameters:
      value - whether this session sends messages back to itself

    • removed

      protected boolean removed(ServerMessage message, boolean timeout)
      Parameters:
      message - the message that caused the removal, or null
      timeout - whether the session has been removed due a timeout
      Returns:
      True if the session was connected.

    • setMetaConnectDeliveryOnly

      public void setMetaConnectDeliveryOnly(boolean meta)
      Description copied from interface: ServerSession

      Sets whether delivery of messages only happen via the /meta/connect channel.

      Transports that use more than one connection to the server (e.g. HTTP transports) may deliver some messages in one connection and some in another connection, causing messages to arrive out-of-order.

      Forcing messages to be delivered only via the /meta/connect channel guarantees server-to-client message ordering.

      Specified by:
      setMetaConnectDeliveryOnly in interface ServerSession
      Parameters:
      meta - whether delivery of messages only happens via the /meta/connect channel

    • isMetaConnectDeliveryOnly

      public boolean isMetaConnectDeliveryOnly()
      Specified by:
      isMetaConnectDeliveryOnly in interface ServerSession
      Returns:
      whether delivery of messages only happens via the /meta/connect channel

    • isAllowMessageDeliveryDuringHandshake

      public boolean isAllowMessageDeliveryDuringHandshake()

    • setAllowMessageDeliveryDuringHandshake

      public void setAllowMessageDeliveryDuringHandshake(boolean allow)

    • subscribe

      protected boolean subscribe(ServerChannelImpl channel)

    • unsubscribedFrom

      protected void unsubscribedFrom(ServerChannelImpl channel)

    • calculateTimeout

      public long calculateTimeout(long defaultTimeout)

    • calculateInterval

      public long calculateInterval(long defaultInterval)

    • updateTransientTimeout

      public void updateTransientTimeout(long timeout)
      Updates the transient timeout with the given value. The transient timeout is the one sent by the client, that should temporarily override the session/transport timeout, for example when the client sends {timeout:0}
      Parameters:
      timeout - the value to update the timeout to
      See Also:

    • updateTransientInterval

      public void updateTransientInterval(long interval)
      Updates the transient interval with the given value. The transient interval is the one sent by the client, that should temporarily override the session/transport interval, for example when the client sends {timeout:0,interval:60000}
      Parameters:
      interval - the value to update the interval to
      See Also:

    • dump

      public void dump(Appendable out, String indent) throws IOException
      Specified by:
      dump in interface org.eclipse.jetty.util.component.Dumpable
      Throws:
      IOException

    • toString

      public String toString()
      Overrides:
      toString in class Object