-
Methods in org.cometd.server with parameters of type ServerSessionImpl
Modifier and Type |
Method |
Description |
protected void |
BayeuxServerImpl.addServerSession(ServerSessionImpl session,
ServerMessage message) |
|
protected boolean |
AbstractServerTransport.allowMessageDeliveryDuringHandshake(ServerSessionImpl session) |
|
protected void |
BayeuxServerImpl.doPublish(ServerSessionImpl from,
ServerChannelImpl to,
ServerMessage.Mutable mutable,
boolean receiving) |
|
protected void |
LocalSessionImpl.doSend(ServerSessionImpl from,
ServerMessage.Mutable message) |
Sends a message to the server.
|
ServerMessage.Mutable |
BayeuxServerImpl.extendReply(ServerSessionImpl from,
ServerSessionImpl to,
ServerMessage.Mutable reply) |
|
ServerMessage.Mutable |
BayeuxServerImpl.handle(ServerSessionImpl session,
ServerMessage.Mutable message) |
|
protected ServerMessage.Mutable |
AbstractServerTransport.processReply(ServerSessionImpl session,
ServerMessage.Mutable reply) |
|
protected void |
AbstractServerTransport.scheduleExpiration(ServerSessionImpl session) |
|
protected void |
LocalSessionImpl.send(ServerSessionImpl session,
ServerMessage.Mutable message) |
Enqueues or sends a message to the server.
|
protected boolean |
ServerChannelImpl.subscribe(ServerSessionImpl session,
ServerMessage message) |
|
protected boolean |
ServerChannelImpl.unsubscribe(ServerSessionImpl session,
ServerMessage message) |
|
-
-
Methods in org.cometd.server.transport with parameters of type ServerSessionImpl
Modifier and Type |
Method |
Description |
protected ServerMessage.Mutable |
AbstractHttpTransport.bayeuxServerHandle(ServerSessionImpl session,
ServerMessage.Mutable message) |
|
protected void |
AbstractHttpTransport.decBrowserId(ServerSessionImpl session,
boolean http2) |
|
protected void |
AbstractHttpTransport.flush(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
boolean sendQueue,
boolean scheduleExpiration,
ServerMessage.Mutable... replies) |
|
protected boolean |
AbstractHttpTransport.incBrowserId(ServerSessionImpl session,
boolean http2) |
Increments the count of sessions for the given browser identifier.
|
protected AbstractHttpTransport.HttpScheduler |
AbstractStreamHttpTransport.newHttpScheduler(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.servlet.AsyncContext asyncContext,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
protected AbstractHttpTransport.HttpScheduler |
AsyncJSONTransport.newHttpScheduler(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.servlet.AsyncContext asyncContext,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
protected ServerMessage.Mutable |
AbstractHttpTransport.processMetaConnect(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
ServerMessage.Mutable message,
boolean canSuspend) |
|
protected ServerMessage.Mutable |
AbstractHttpTransport.processMetaHandshake(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
ServerMessage.Mutable message) |
|
protected void |
AbstractHttpTransport.resume(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.servlet.AsyncContext asyncContext,
ServerSessionImpl session,
ServerMessage.Mutable reply) |
|
protected abstract AbstractHttpTransport.HttpScheduler |
AbstractHttpTransport.suspend(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
protected AbstractHttpTransport.HttpScheduler |
AbstractStreamHttpTransport.suspend(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
protected AbstractHttpTransport.HttpScheduler |
AsyncJSONTransport.suspend(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
protected abstract void |
AbstractHttpTransport.write(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
boolean scheduleExpiration,
List<ServerMessage> messages,
ServerMessage.Mutable[] replies) |
|
protected void |
AbstractStreamHttpTransport.write(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
boolean scheduleExpiration,
List<ServerMessage> messages,
ServerMessage.Mutable[] replies) |
|
protected void |
AsyncJSONTransport.write(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
boolean scheduleExpiration,
List<ServerMessage> messages,
ServerMessage.Mutable[] replies) |
|
protected void |
AbstractStreamHttpTransport.writeComplete(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
List<ServerMessage> messages,
ServerMessage.Mutable[] replies) |
|
protected void |
AsyncJSONTransport.writeComplete(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
List<ServerMessage> messages,
ServerMessage.Mutable[] replies) |
|
protected void |
AbstractStreamHttpTransport.writeMessage(javax.servlet.http.HttpServletResponse response,
javax.servlet.ServletOutputStream output,
ServerSessionImpl session,
ServerMessage message) |
|
Constructors in org.cometd.server.transport with parameters of type ServerSessionImpl
Constructor |
Description |
DispatchingLongPollScheduler(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.servlet.AsyncContext asyncContext,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
LongPollScheduler(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.servlet.AsyncContext asyncContext,
ServerSessionImpl session,
ServerMessage.Mutable reply,
long timeout) |
|
Writer(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.servlet.AsyncContext asyncContext,
ServerSessionImpl session,
boolean scheduleExpiration,
List<ServerMessage> messages,
ServerMessage.Mutable[] replies) |
|
-