Package org.cometd.bayeux.server

Interface ServerSession

All Superinterfaces:

Session

All Known Implementing Classes:

ServerSessionImpl

public interface ServerSession
extends Session

Objects implementing this interface are the server-side representation of remote Bayeux clients.

ServerSession contains the queue of messages to be delivered to the client; messages are normally queued on a ServerSession by publishing them to a channel to which the session is subscribed (via ServerChannel.publish(Session, ServerMessage.Mutable, Promise).

The deliver(Session, ServerMessage.Mutable, Promise) and deliver(Session, String, Object, Promise) methods may be used to directly queue messages to a session without publishing them to all subscribers of a channel.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ServerSession.AddedListener	Listener objects that implement this interface will be notified of session addition.
static interface	ServerSession.DeQueueListener	Listeners objects that implement this interface will be notified when the session queue is being drained to actually deliver the messages.
static interface	ServerSession.Extension	Extension API for ServerSession.
static interface	ServerSession.HeartBeatListener	Listeners objects that implement this interface will be notified when a /meta/connect message is suspended by the server, and when it is subsequently resumed.
static interface	ServerSession.MessageListener	Listeners objects that implement this interface will be notified of message sending.
static interface	ServerSession.QueueListener	Listener objects that implement this interface will be notified when a message is queued in the session queue.
static interface	ServerSession.QueueMaxedListener	Listeners objects that implement this interface will be notified when the session queue is full.
static interface	ServerSession.RemovedListener	Listeners objects that implement this interface will be notified of session removal.
static interface	ServerSession.ServerSessionListener	Common interface for ServerSession listeners.

Method Summary

Modifier and Type	Method	Description
void	addExtension(ServerSession.Extension extension)	Adds the given extension to this session.
void	addListener(ServerSession.ServerSessionListener listener)	Adds the given listener to this session.
void	deliver(Session sender, String channel, 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.
List<ServerSession.Extension>	getExtensions()
long	getInterval()
LocalSession	getLocalSession()
long	getMaxInterval()
ServerTransport	getServerTransport()
Set<ServerChannel>	getSubscriptions()
long	getTimeout()
String	getUserAgent()
boolean	isBroadcastToPublisher()
boolean	isLocalSession()
boolean	isMetaConnectDeliveryOnly()
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	setBroadcastToPublisher(boolean broadcastToPublisher)	Sets whether this session sends messages back to itself.
void	setInterval(long interval)
void	setMaxInterval(long maxInterval)
void	setMetaConnectDeliveryOnly(boolean metaConnectDeliveryOnly)	Sets whether delivery of messages only happen via the /meta/connect channel.
void	setTimeout(long timeout)

Methods inherited from interface org.cometd.bayeux.Session

batch, disconnect, endBatch, getAttribute, getAttributeNames, getId, isConnected, isHandshook, removeAttribute, setAttribute, startBatch

Method Details

addExtension

void addExtension(ServerSession.Extension extension)

Adds the given extension to this session.

Parameters:

extension - the extension to add

See Also:

• removeExtension(Extension)

removeExtension

void removeExtension(ServerSession.Extension extension)

Removes the given extension from this session.

Parameters:

extension - the extension to remove

See Also:

• addExtension(Extension)

getExtensions

List<ServerSession.Extension> getExtensions()

Returns:

an immutable list of extensions present in this ServerSession instance

See Also:

• addExtension(Extension)

addListener

void addListener(ServerSession.ServerSessionListener listener)

Adds the given listener to this session.

Parameters:

listener - the listener to add

See Also:

• removeListener(ServerSessionListener)

removeListener

void removeListener(ServerSession.ServerSessionListener listener)

Removes the given listener from this session.

Parameters:

listener - the listener to remove

See Also:

• addListener(ServerSessionListener)

getServerTransport

ServerTransport getServerTransport()

Returns:

the ServerTransport associated with this session

isLocalSession

boolean isLocalSession()

Returns:

whether this is a session for a local client on server-side

getLocalSession

LocalSession getLocalSession()

Returns:

the LocalSession associated with this session, or null if this is a session representing a remote client.

deliver

void deliver(Session sender,
 ServerMessage.Mutable message,
 Promise<Boolean> promise)

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.

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(Session, String, Object, Promise)

deliver

void deliver(Session sender,
 String channel,
 Object data,
 Promise<Boolean> promise)

Delivers the given information to this session.

Parameters:

sender - the session delivering the message

channel - the channel of the message

data - the data of the message

promise - the promise to notify with the result of the deliver

See Also:

• deliver(Session, ServerMessage.Mutable, Promise)

getSubscriptions

Set<ServerChannel> getSubscriptions()

Returns:

the set of channels to which this session is subscribed to

getUserAgent

String getUserAgent()

Returns:

The string indicating the client user agent, or null if not known

getInterval

long getInterval()

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()
• setInterval(long)

setInterval

void setInterval(long interval)

Parameters:

interval - the period of time, in milliseconds, that the client associated with this session will wait before issuing a connect message

getTimeout

long getTimeout()

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()

setTimeout

void setTimeout(long timeout)

Parameters:

timeout - the period of time, in milliseconds, that the server will hold connect messages for this session

getMaxInterval

long getMaxInterval()

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

void setMaxInterval(long maxInterval)

Parameters:

maxInterval - the max period of time, in milliseconds, that the server waits before expiring the session

isMetaConnectDeliveryOnly

boolean isMetaConnectDeliveryOnly()

Returns:

whether delivery of messages only happens via the /meta/connect channel

setMetaConnectDeliveryOnly

void setMetaConnectDeliveryOnly(boolean metaConnectDeliveryOnly)

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.

Parameters:

metaConnectDeliveryOnly - whether delivery of messages only happens via the /meta/connect channel

isBroadcastToPublisher

boolean isBroadcastToPublisher()

Returns:

whether this session sends messages back to itself

setBroadcastToPublisher

void setBroadcastToPublisher(boolean broadcastToPublisher)

Sets whether this session sends messages back to itself.

Parameters:

broadcastToPublisher - whether this session sends messages back to itself