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

Nested Class Summary
- Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
  org.eclipse.jetty.util.component.Dumpable.DumpableContainer
- Nested classes/interfaces inherited from interface org.cometd.bayeux.server.ServerSession
  ServerSession.AddListener, ServerSession.DeQueueListener, ServerSession.Extension, ServerSession.HeartBeatListener, ServerSession.MaxQueueListener, ServerSession.MessageListener, ServerSession.QueueListener, ServerSession.RemoveListener, ServerSession.ServerSessionListener

Field Summary
- Fields inherited from interface org.eclipse.jetty.util.component.Dumpable
  KEY

Constructor Summary

Constructors
Constructor	Description
`ServerSessionImpl(BayeuxServerImpl bayeux)`
`ServerSessionImpl(BayeuxServerImpl bayeux, LocalSessionImpl localSession, String idHint)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`added()`
`void`	`addExtension(ServerSession.Extension extension)`	Adds the given extension to this session.
`void`	`addListener(ServerSession.ServerSessionListener listener)`	Adds the given listener to this session.
`protected void`	`addMessage(ServerMessage message)`
`void`	`batch(Runnable batch)`	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.
`long`	`calculateInterval(long defaultInterval)`
`long`	`calculateTimeout(long defaultTimeout)`
`void`	`cancelExpiration(boolean metaConnect)`
`protected boolean`	`connected()`
`void`	`deliver(Session sender, String channelId, Object data, Promise<Boolean> promise)`	Delivers the given information to this session.
`void`	`deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise)`	Delivers the given message to this session.
`protected void`	`deliver1(ServerSession sender, ServerMessage.Mutable mutable, Promise<Boolean> promise)`
`void`	`destroyScheduler()`
`void`	`disconnect()`	Disconnects this session, ending the link between the client and the server peers.
`void`	`dump(Appendable out, String indent)`
`boolean`	`endBatch()`	Ends a batch started with `Session.startBatch()`.
`protected void`	`extendIncoming(ServerMessage.Mutable message, Promise<Boolean> promise)`
`protected void`	`extendOutgoing(ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)`
`void`	`flush()`
`Object`	`getAttribute(String name)`	Retrieves the value of named session attribute.
`Set<String>`	`getAttributeNames()`
`BayeuxServerImpl`	`getBayeuxServer()`
`String`	`getBrowserId()`
`List<ServerSession.Extension>`	`getExtensions()`
`String`	`getId()`	The clientId of the session.
`long`	`getInterval()`
`List<ServerSession.ServerSessionListener>`	`getListeners()`
`LocalSession`	`getLocalSession()`
`Object`	`getLock()`
`long`	`getMaxInterval()`
`Queue<ServerMessage>`	`getQueue()`
`ServerTransport`	`getServerTransport()`
`Set<ServerChannel>`	`getSubscriptions()`
`long`	`getTimeout()`
`String`	`getUserAgent()`
`protected boolean`	`handshake(ServerMessage.Mutable message)`
`boolean`	`hasNonLazyMessages()`
`boolean`	`isAllowMessageDeliveryDuringHandshake()`
`boolean`	`isBroadcastToPublisher()`
`boolean`	`isConnected()`	A connected session is a session where the link between the client and the server has been established.
`boolean`	`isDisconnected()`
`boolean`	`isHandshook()`	A handshook session is a session where the handshake has successfully completed
`boolean`	`isLocalSession()`
`boolean`	`isMetaConnectDeliveryOnly()`
`boolean`	`isTerminated()`
`void`	`notifyResumed(ServerMessage message, boolean timeout)`
`void`	`notifySuspended(ServerMessage message, long timeout)`
`void`	`reAdvise()`
`Object`	`removeAttribute(String name)`	Removes a named session attribute.
`protected boolean`	`removed(boolean timedOut)`
`void`	`removeExtension(ServerSession.Extension extension)`	Removes the given extension from this session.
`void`	`removeListener(ServerSession.ServerSessionListener listener)`	Removes the given listener from this session.
`void`	`scheduleExpiration(long defaultInterval, long defaultMaxInterval)`
`void`	`setAllowMessageDeliveryDuringHandshake(boolean allow)`
`void`	`setAttribute(String name, Object value)`	Sets a named session attribute value.
`void`	`setBroadcastToPublisher(boolean value)`
`void`	`setBrowserId(String browserId)`	Sets a remote client identifier, typically a browser.
`void`	`setInterval(long intervalMS)`
`void`	`setMaxInterval(long maxInterval)`
`void`	`setMetaConnectDeliveryOnly(boolean meta)`
`void`	`setScheduler(AbstractServerTransport.Scheduler newScheduler)`
`void`	`setServerTransport(ServerTransport transport)`
`void`	`setTimeout(long timeoutMS)`
`void`	`setUserAgent(String userAgent)`
`boolean`	`shouldSchedule()`
`void`	`startBatch()`	Starts a batch, to be ended with `Session.endBatch()`.
`protected boolean`	`subscribe(ServerChannelImpl channel)`
`protected void`	`sweep(long now)`
`Map<String,Object>`	`takeAdvice(ServerTransport transport)`
`List<ServerMessage>`	`takeQueue(List<ServerMessage.Mutable> replies)`
`String`	`toString()`
`protected void`	`unsubscribedFrom(ServerChannelImpl channel)`
`void`	`updateTransientInterval(long interval)`	Updates the transient interval with the given value.
`void`	`updateTransientTimeout(long timeout)`	Updates the transient timeout with the given value.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable
dump, dumpSelf

Methods inherited from interface org.cometd.bayeux.server.ServerSession
deliver, deliver

- Constructor Detail
  - ServerSessionImpl
```
public ServerSessionImpl(BayeuxServerImpl bayeux)
```
  - ServerSessionImpl
```
public ServerSessionImpl(BayeuxServerImpl bayeux,
                         LocalSessionImpl localSession,
                         String idHint)
```
- Method Detail
  - 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 void 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:
    
    ServerSession.removeExtension(Extension)
  - 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:
    
    ServerSession.addExtension(Extension)
  - 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:
    
    ServerSession.addExtension(Extension)
  - 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:
    
    ServerSession.deliver(Session, String, Object, Promise)
  - 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:
    
    ServerSession.deliver(Session, ServerMessage.Mutable, Promise)
  - deliver1
```
protected void deliver1(ServerSession sender,
                        ServerMessage.Mutable mutable,
                        Promise<Boolean> promise)
```
  - extendOutgoing
```
protected void extendOutgoing(ServerMessage.Mutable message,
                              Promise<ServerMessage.Mutable> promise)
```
  - handshake
```
protected boolean handshake(ServerMessage.Mutable message)
```
  - connected
```
protected 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:
    
    Session.isConnected()
  - 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:
    
    Session.endBatch(), Session.batch(Runnable)
  - 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:
    
    Session.startBatch()
  - 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:
    
    ServerSession.removeListener(ServerSessionListener)
  - 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 Object 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:
    
    ServerSession.addListener(ServerSessionListener)
  - 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)
```
  - 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
  - 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 list of 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:
    
    Session.disconnect()
  - 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)
```
  - 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:
    
    ServerTransport.getTimeout()
  - 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:
    
    ServerTransport.getInterval(), ServerSession.setInterval(long)
  - 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()
```
  - setBroadcastToPublisher
```
public void setBroadcastToPublisher(boolean value)
```
  - added
```
protected void added()
```
  - removed
```
protected boolean removed(boolean timedOut)
```
    Parameters:
    
    timedOut - whether the session has been timed out
    
    Returns:
    
    True if the session was connected.
  - setMetaConnectDeliveryOnly
```
public void setMetaConnectDeliveryOnly(boolean meta)
```
  - isMetaConnectDeliveryOnly
```
public boolean isMetaConnectDeliveryOnly()
```
  - 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(long)
  - 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:
    
    updateTransientTimeout(long)
  - 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

Class ServerSessionImpl

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

Nested classes/interfaces inherited from interface org.cometd.bayeux.server.ServerSession

Field Summary

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

Methods inherited from interface org.cometd.bayeux.server.ServerSession

Constructor Detail

ServerSessionImpl

ServerSessionImpl

Method Detail

getBayeuxServer

getUserAgent

setUserAgent

getBrowserId

setBrowserId

sweep

getSubscriptions

addExtension

removeExtension

getExtensions

batch

deliver

deliver

deliver1

extendOutgoing

handshake

connected

disconnect

startBatch

endBatch

getLocalSession

isLocalSession

addListener

getId

getLock

getQueue

hasNonLazyMessages

addMessage

takeQueue

notifySuspended

notifyResumed

removeListener

getListeners

setScheduler

shouldSchedule

flush

destroyScheduler

cancelExpiration

scheduleExpiration

getMaxInterval

setMaxInterval

getAttribute

getAttributeNames

removeAttribute

setAttribute

isHandshook

isConnected

isDisconnected

isTerminated

extendIncoming

reAdvise

takeAdvice

getServerTransport

setServerTransport

getTimeout

getInterval

setTimeout

setInterval

isBroadcastToPublisher

setBroadcastToPublisher

added

removed

setMetaConnectDeliveryOnly

isMetaConnectDeliveryOnly

isAllowMessageDeliveryDuringHandshake