Package org.cometd.server.http
Class AbstractHttpTransport
java.lang.Object
org.cometd.common.AbstractTransport
org.cometd.server.AbstractServerTransport
org.cometd.server.http.AbstractHttpTransport
- All Implemented Interfaces:
ServerTransport
,Transport
,org.eclipse.jetty.util.component.Dumpable
- Direct Known Subclasses:
AbstractStreamHttpTransport
,AsyncJSONTransport
HTTP ServerTransport base class, used by ServerTransports that use HTTP as transport or to initiate a transport connection.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
static interface
AAbstractServerTransport.Scheduler
for HTTP-based transports.protected class
Nested classes/interfaces inherited from class org.cometd.server.AbstractServerTransport
AbstractServerTransport.Scheduler
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
org.eclipse.jetty.util.component.Dumpable.DumpableContainer
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
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
Fields inherited from interface org.eclipse.jetty.util.component.Dumpable
KEY
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
AbstractHttpTransport
(BayeuxServerImpl bayeux, String name) -
Method Summary
Modifier and TypeMethodDescriptionabstract boolean
accept
(javax.servlet.http.HttpServletRequest request) protected void
decBrowserId
(ServerSessionImpl session, boolean http2) protected String
protected Collection<ServerSessionImpl>
findCurrentSessions
(javax.servlet.http.HttpServletRequest request) protected ServerSessionImpl
findSession
(Collection<ServerSessionImpl> sessions, ServerMessage.Mutable message) protected void
flush
(AbstractHttpTransport.Context context, Promise<Void> promise) protected javax.servlet.AsyncContext
getAsyncContext
(javax.servlet.http.HttpServletRequest request) protected int
protected long
abstract void
handle
(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) protected void
handleJSONParseException
(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, String json, Throwable failure) protected void
handleMessage
(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise) protected boolean
incBrowserId
(ServerSessionImpl session, boolean http2) Increments the count of sessions for the given browser identifier.void
init()
Initializes the transport, resolving default and direct options.protected boolean
isHTTP2
(javax.servlet.http.HttpServletRequest request) protected void
processMessages
(AbstractHttpTransport.Context context, List<ServerMessage.Mutable> messages, Promise<Void> promise) protected void
resume
(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<Void> promise) protected void
sendError
(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, int code, Throwable failure) protected String
protected abstract AbstractHttpTransport.HttpScheduler
suspend
(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout) protected void
sweep()
Sweeps the transport for old Browser IDsprotected byte[]
toJSONBytes
(ServerMessage msg) protected abstract void
write
(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise) Methods inherited from class org.cometd.server.AbstractServerTransport
allowMessageDeliveryDuringHandshake, destroy, dump, getBayeux, getInterval, getJSONContextServer, getMaxInterval, getMaxLazyTimeout, getMaxMessageSize, getTimeout, isAllowMessageDeliveryDuringHandshake, isHandshakeReconnect, isMetaConnectDeliveryOnly, newMetaConnectCycle, parseMessages, parseMessages, processReply, scheduleExpiration, setAllowMessageDeliveryDuringHandshake, setHandshakeReconnect, setInterval, setMaxInterval, setMaxLazyTimeout, setMaxMessageSize, setMetaConnectDeliveryOnly, setTimeout, toJSON, 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.eclipse.jetty.util.component.Dumpable
dump, dumpSelf
Methods inherited from interface org.cometd.bayeux.Transport
getName, getOption, getOptionNames, getOptionPrefix
-
Field Details
-
PREFIX
- See Also:
-
JSON_DEBUG_OPTION
- See Also:
-
MESSAGE_PARAM
- See Also:
-
BROWSER_COOKIE_NAME_OPTION
- See Also:
-
BROWSER_COOKIE_DOMAIN_OPTION
- See Also:
-
BROWSER_COOKIE_PATH_OPTION
- See Also:
-
BROWSER_COOKIE_SECURE_OPTION
- See Also:
-
BROWSER_COOKIE_HTTP_ONLY_OPTION
- See Also:
-
BROWSER_COOKIE_SAME_SITE_OPTION
- See Also:
-
MAX_SESSIONS_PER_BROWSER_OPTION
- See Also:
-
HTTP2_MAX_SESSIONS_PER_BROWSER_OPTION
- See Also:
-
MULTI_SESSION_INTERVAL_OPTION
- See Also:
-
TRUST_CLIENT_SESSION_OPTION
- See Also:
-
DUPLICATE_META_CONNECT_HTTP_RESPONSE_CODE_OPTION
- See Also:
-
-
Constructor Details
-
AbstractHttpTransport
-
-
Method Details
-
init
public void init()Description copied from class:AbstractServerTransport
Initializes the transport, resolving default and direct options.- Overrides:
init
in classAbstractServerTransport
-
getMultiSessionInterval
protected long getMultiSessionInterval() -
getDuplicateMetaConnectHttpResponseCode
protected int getDuplicateMetaConnectHttpResponseCode() -
accept
public abstract boolean accept(javax.servlet.http.HttpServletRequest request) -
handle
public abstract void handle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws IOException, javax.servlet.ServletException - Throws:
IOException
javax.servlet.ServletException
-
suspend
protected abstract AbstractHttpTransport.HttpScheduler suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout) -
write
protected abstract void write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise) -
processMessages
protected void processMessages(AbstractHttpTransport.Context context, List<ServerMessage.Mutable> messages, Promise<Void> promise) -
findSession
protected ServerSessionImpl findSession(Collection<ServerSessionImpl> sessions, ServerMessage.Mutable message) -
findCurrentSessions
protected Collection<ServerSessionImpl> findCurrentSessions(javax.servlet.http.HttpServletRequest request) -
isHTTP2
protected boolean isHTTP2(javax.servlet.http.HttpServletRequest request) -
flush
-
resume
protected void resume(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<Void> promise) -
sendError
protected void sendError(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, int code, Throwable failure) -
findBrowserId
-
setBrowserId
-
incBrowserId
Increments the count of sessions for the given browser identifier.- Parameters:
session
- the session that increments the counthttp2
- whether the HTTP protocol is HTTP/2- Returns:
- true if the count is below the max sessions per browser value. If false is returned, the count is not incremented.
- See Also:
-
decBrowserId
-
handleJSONParseException
protected void handleJSONParseException(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, String json, Throwable failure) throws IOException - Throws:
IOException
-
handleMessage
protected void handleMessage(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise) -
getAsyncContext
protected javax.servlet.AsyncContext getAsyncContext(javax.servlet.http.HttpServletRequest request) -
sweep
protected void sweep()Sweeps the transport for old Browser IDs- Overrides:
sweep
in classAbstractServerTransport
-
toJSONBytes
-