-
Methods in org.cometd.bayeux.server with parameters of type ServerMessage.Mutable
Modifier and Type |
Method |
Description |
void |
ServerSession.deliver(Session sender,
ServerMessage.Mutable message) |
Delivers the given message to this session.
|
boolean |
ServerChannel.MessageListener.onMessage(ServerSession from,
ServerChannel channel,
ServerMessage.Mutable message) |
Callback invoked when a message is being published.
|
void |
ServerChannel.publish(Session from,
ServerMessage.Mutable message) |
Publishes the given message to this channel, delivering
the message to all the ServerSession s subscribed to
this channel.
|
boolean |
BayeuxServer.Extension.Adapter.rcv(ServerSession from,
ServerMessage.Mutable message) |
|
boolean |
BayeuxServer.Extension.rcv(ServerSession from,
ServerMessage.Mutable message) |
Callback method invoked every time a normal message is incoming.
|
boolean |
ServerSession.Extension.Adapter.rcv(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
ServerSession.Extension.rcv(ServerSession session,
ServerMessage.Mutable message) |
Callback method invoked every time a normal message is incoming.
|
boolean |
BayeuxServer.Extension.Adapter.rcvMeta(ServerSession from,
ServerMessage.Mutable message) |
|
boolean |
BayeuxServer.Extension.rcvMeta(ServerSession from,
ServerMessage.Mutable message) |
Callback method invoked every time a meta message is incoming.
|
boolean |
ServerSession.Extension.Adapter.rcvMeta(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
ServerSession.Extension.rcvMeta(ServerSession session,
ServerMessage.Mutable message) |
Callback method invoked every time a meta message is incoming.
|
boolean |
BayeuxServer.Extension.Adapter.send(ServerSession from,
ServerSession to,
ServerMessage.Mutable message) |
|
boolean |
BayeuxServer.Extension.send(ServerSession from,
ServerSession to,
ServerMessage.Mutable message) |
Callback method invoked every time a normal message is outgoing.
|
boolean |
BayeuxServer.Extension.Adapter.sendMeta(ServerSession to,
ServerMessage.Mutable message) |
|
boolean |
BayeuxServer.Extension.sendMeta(ServerSession to,
ServerMessage.Mutable message) |
Callback method invoked every time a meta message is outgoing.
|
boolean |
ServerSession.Extension.Adapter.sendMeta(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
ServerSession.Extension.sendMeta(ServerSession session,
ServerMessage.Mutable message) |
Callback method invoked every time a meta message is outgoing.
|
void |
ServerMessage.Mutable.setAssociated(ServerMessage.Mutable message) |
|
-
-
Methods in org.cometd.server with parameters of type ServerMessage.Mutable
Modifier and Type |
Method |
Description |
protected ServerMessage.Mutable |
BayeuxServerImpl.createReply(ServerMessage.Mutable message) |
|
void |
ServerSessionImpl.deliver(Session sender,
ServerMessage.Mutable message) |
|
protected void |
ServerSessionImpl.doDeliver(ServerSession sender,
ServerMessage.Mutable mutable) |
|
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.
|
protected void |
BayeuxServerImpl.error(ServerMessage.Mutable reply,
String error) |
|
protected boolean |
BayeuxServerImpl.extendRecv(ServerSession from,
ServerMessage.Mutable message) |
|
protected boolean |
ServerSessionImpl.extendRecv(ServerMessage.Mutable message) |
|
ServerMessage.Mutable |
BayeuxServerImpl.extendReply(ServerSessionImpl from,
ServerSessionImpl to,
ServerMessage.Mutable reply) |
|
protected boolean |
BayeuxServerImpl.extendSend(ServerSession from,
ServerSession to,
ServerMessage.Mutable message) |
|
protected ServerMessage.Mutable |
ServerSessionImpl.extendSend(ServerMessage.Mutable mutable) |
|
void |
BayeuxServerImpl.freeze(ServerMessage.Mutable mutable) |
|
ServerMessage.Mutable |
BayeuxServerImpl.handle(ServerSessionImpl session,
ServerMessage.Mutable message) |
|
protected ServerMessage.Mutable |
AbstractServerTransport.processReply(ServerSessionImpl session,
ServerMessage.Mutable reply) |
|
void |
ServerChannelImpl.publish(Session from,
ServerMessage.Mutable mutable) |
|
protected void |
LocalSessionImpl.send(ServerSessionImpl session,
ServerMessage.Mutable message) |
Enqueues or sends a message to the server.
|
void |
ServerMessageImpl.setAssociated(ServerMessage.Mutable associated) |
|
protected void |
BayeuxServerImpl.unknownSession(ServerMessage.Mutable reply) |
|
protected void |
BayeuxServerImpl.validateMessage(ServerMessage.Mutable message) |
|
-
Methods in org.cometd.server.ext with parameters of type ServerMessage.Mutable
Modifier and Type |
Method |
Description |
boolean |
AcknowledgedMessagesSessionExtension.rcv(ServerSession from,
ServerMessage.Mutable message) |
|
boolean |
ActivityExtension.SessionExtension.rcv(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
BinaryExtension.rcv(ServerSession from,
ServerMessage.Mutable message) |
|
boolean |
BinarySessionExtension.rcv(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
AcknowledgedMessagesExtension.rcvMeta(ServerSession remote,
ServerMessage.Mutable message) |
|
boolean |
AcknowledgedMessagesSessionExtension.rcvMeta(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
ActivityExtension.rcvMeta(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
ActivityExtension.SessionExtension.rcvMeta(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
TimesyncExtension.rcvMeta(ServerSession from,
ServerMessage.Mutable message) |
|
boolean |
BinaryExtension.send(ServerSession from,
ServerSession to,
ServerMessage.Mutable message) |
|
boolean |
TimestampExtension.send(ServerSession from,
ServerSession to,
ServerMessage.Mutable message) |
|
boolean |
AcknowledgedMessagesSessionExtension.sendMeta(ServerSession to,
ServerMessage.Mutable message) |
|
boolean |
ActivityExtension.SessionExtension.sendMeta(ServerSession session,
ServerMessage.Mutable message) |
|
boolean |
TimestampExtension.sendMeta(ServerSession to,
ServerMessage.Mutable message) |
|
boolean |
TimesyncExtension.sendMeta(ServerSession session,
ServerMessage.Mutable message) |
|
-
-
Methods in org.cometd.server.transport with parameters of type ServerMessage.Mutable
Modifier and Type |
Method |
Description |
protected ServerMessage.Mutable |
AbstractHttpTransport.bayeuxServerHandle(ServerSessionImpl session,
ServerMessage.Mutable message) |
|
protected ServerSessionImpl |
AbstractHttpTransport.findSession(Collection<ServerSessionImpl> sessions,
ServerMessage.Mutable message) |
|
protected void |
AbstractHttpTransport.flush(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerSessionImpl session,
boolean sendQueue,
boolean scheduleExpiration,
ServerMessage.Mutable... replies) |
|
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 void |
AbstractHttpTransport.processMessages(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
ServerMessage.Mutable[] messages) |
|
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) |
|
Constructors in org.cometd.server.transport with parameters of type ServerMessage.Mutable
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) |
|
-