Package org.cometd.server.transport

Class AsyncJSONTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.server.AbstractServerTransport

org.cometd.server.transport.AbstractHttpTransport

org.cometd.server.transport.AsyncJSONTransport

All Implemented Interfaces:

ServerTransport, Transport, org.eclipse.jetty.util.component.Dumpable

public class AsyncJSONTransport
extends AbstractHttpTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	AsyncJSONTransport.AbstractReader
protected class	AsyncJSONTransport.CharsetReader
protected class	AsyncJSONTransport.UTF8Reader
protected class	AsyncJSONTransport.Writer

Nested classes/interfaces inherited from class org.cometd.server.transport.AbstractHttpTransport

AbstractHttpTransport.HttpScheduler, AbstractHttpTransport.LongPollScheduler

Nested classes/interfaces inherited from class org.cometd.server.AbstractServerTransport

AbstractServerTransport.Scheduler

Field Summary

Fields inherited from class org.cometd.server.transport.AbstractHttpTransport

_logger, BROWSER_COOKIE_DOMAIN_OPTION, BROWSER_COOKIE_HTTP_ONLY_OPTION, BROWSER_COOKIE_NAME_OPTION, BROWSER_COOKIE_PATH_OPTION, BROWSER_COOKIE_SAME_SITE_OPTION, BROWSER_COOKIE_SECURE_OPTION, DUPLICATE_META_CONNECT_HTTP_RESPONSE_CODE_OPTION, HTTP2_MAX_SESSIONS_PER_BROWSER_OPTION, JSON_DEBUG_OPTION, MAX_SESSIONS_PER_BROWSER_OPTION, MESSAGE_PARAM, MULTI_SESSION_INTERVAL_OPTION, TRUST_CLIENT_SESSION, TRUST_CLIENT_SESSION_OPTION

Fields inherited from class org.cometd.server.AbstractServerTransport

ALLOW_MESSAGE_DELIVERY_DURING_HANDSHAKE, HANDSHAKE_RECONNECT_OPTION, INTERVAL_OPTION, JSON_CONTEXT_OPTION, MAX_INTERVAL_OPTION, MAX_LAZY_TIMEOUT_OPTION, MAX_MESSAGE_SIZE_OPTION, MAX_PROCESSING_OPTION, MAX_QUEUE_OPTION, META_CONNECT_DELIVERY_OPTION, TIMEOUT_OPTION

Constructor Summary

Constructors

Constructor	Description
AsyncJSONTransport(BayeuxServerImpl bayeux)

Method Summary

Modifier and Type	Method	Description
boolean	accept(javax.servlet.http.HttpServletRequest request)
void	handle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
protected AbstractHttpTransport.HttpScheduler	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	suspend(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, ServerMessage.Mutable reply, long timeout)
protected void	write(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, boolean scheduleExpiration, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
protected void	writeComplete(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, List<ServerMessage> messages, ServerMessage.Mutable[] replies)

Methods inherited from class org.cometd.server.transport.AbstractHttpTransport

bayeuxServerHandle, decBrowserId, error, findBrowserId, findCurrentSessions, findSession, flush, getAsyncContext, getContext, getCurrentRequest, getMultiSessionInterval, handleJSONParseException, incBrowserId, init, isHTTP2, metaConnectResumed, metaConnectSuspended, processMessages, processMetaConnect, processMetaHandshake, resume, setBrowserId, setCurrentRequest, sweep

Methods inherited from class org.cometd.server.AbstractServerTransport

allowMessageDeliveryDuringHandshake, destroy, dump, dump, getAdvice, getBayeux, getInterval, getMaxInterval, getMaxLazyTimeout, getMaxMessageSize, getTimeout, isAllowMessageDeliveryDuringHandshake, isHandshakeReconnect, isMetaConnectDeliveryOnly, parseMessages, parseMessages, processReply, scheduleExpiration, setAllowMessageDeliveryDuringHandshake, setHandshakeReconnect, setInterval, setMaxInterval, setMaxLazyTimeout, setMaxMessageSize, setMetaConnectDeliveryOnly, setTimeout, toJSONBytes, toString

Methods inherited from class org.cometd.common.AbstractTransport

getName, getOption, getOption, getOption, getOption, getOption, getOptionNames, getOptionPrefix, setOption, setOptionPrefix

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.cometd.bayeux.Transport

getName, getOption, getOptionNames, getOptionPrefix

Constructor Details

AsyncJSONTransport

public AsyncJSONTransport(BayeuxServerImpl bayeux)

Method Details

accept

public boolean accept(javax.servlet.http.HttpServletRequest request)

Specified by:

accept in class AbstractHttpTransport

handle

public void handle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws IOException, javax.servlet.ServletException

Specified by:

handle in class AbstractHttpTransport

Throws:

IOException

javax.servlet.ServletException

suspend

protected AbstractHttpTransport.HttpScheduler suspend(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, ServerMessage.Mutable reply, long timeout)

Specified by:

suspend in class AbstractHttpTransport

newHttpScheduler

protected AbstractHttpTransport.HttpScheduler newHttpScheduler(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, javax.servlet.AsyncContext asyncContext, ServerSessionImpl session, ServerMessage.Mutable reply, long timeout)

write

protected void write(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, boolean scheduleExpiration, List<ServerMessage> messages, ServerMessage.Mutable[] replies)

Specified by:

write in class AbstractHttpTransport

writeComplete

protected void writeComplete(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, List<ServerMessage> messages, ServerMessage.Mutable[] replies)