Modifier and Type | Method and Description |
---|---|
protected void |
ServiceInterceptor.mapAnnotatedService(AtmosphereRequest request,
AtmosphereFramework.AtmosphereHandlerWrapper w)
Inspect the request and its mapped
AtmosphereHandler to determine if the '{}' was used when defined the
annotation's path value. |
protected abstract void |
ServiceInterceptor.mapAnnotatedService(boolean reMap,
String path,
AtmosphereRequest request,
AtmosphereFramework.AtmosphereHandlerWrapper w) |
protected void |
MeteorServiceInterceptor.mapAnnotatedService(boolean reMap,
String path,
AtmosphereRequest request,
AtmosphereFramework.AtmosphereHandlerWrapper w) |
protected void |
ManagedServiceInterceptor.mapAnnotatedService(boolean reMap,
String path,
AtmosphereRequest request,
AtmosphereFramework.AtmosphereHandlerWrapper w) |
protected void |
AtmosphereHandlerServiceInterceptor.mapAnnotatedService(boolean reMap,
String path,
AtmosphereRequest request,
AtmosphereFramework.AtmosphereHandlerWrapper w) |
Modifier and Type | Method and Description |
---|---|
Action |
TomcatCometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Tomcat7CometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Servlet30CometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
JettyCometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
JBossWebCometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
GrizzlyCometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Grizzly2CometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
GlassFishv2CometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
BlockingIOCometSupport.cancelled(AtmosphereRequest req,
AtmosphereResponse res) |
static Action |
JettyWebSocketUtil.doService(AsynchronousProcessor cometSupport,
AtmosphereRequest req,
AtmosphereResponse res,
org.eclipse.jetty.websocket.WebSocketFactory webSocketFactory) |
Action |
TomcatWebSocketUtil.Delegate.doService(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Tomcat7Servlet30SupportWithWebSocket.doService(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Tomcat7BIOSupportWithWebSocket.doService(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Tomcat7AsyncSupportWithWebSocket.doService(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
JBossAsyncSupportWithWebSocket.doService(AtmosphereRequest req,
AtmosphereResponse res) |
static Action |
TomcatWebSocketUtil.doService(AtmosphereRequest req,
AtmosphereResponse res,
TomcatWebSocketUtil.Delegate delegate,
AtmosphereConfig config,
WebSocketProcessor webSocketProcessor) |
void |
Servlet30CometSupport.endAsyncContext(AtmosphereRequest request) |
protected org.eclipse.jetty.continuation.Continuation |
Jetty7CometSupport.getContinuation(AtmosphereRequest req) |
Action |
TomcatCometSupport.service(AtmosphereRequest req,
AtmosphereResponse res)
Invoked by the Tomcat AIO when a Comet request gets detected.
|
Action |
Tomcat7Servlet30SupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Tomcat7CometSupport.service(AtmosphereRequest req,
AtmosphereResponse res)
Invoked by the Tomcat AIO when a Comet request gets detected.
|
Action |
Tomcat7BIOSupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Tomcat7AsyncSupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Servlet30CometSupport.service(AtmosphereRequest request,
AtmosphereResponse response) |
Action |
NettyCometSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
JettyServlet30AsyncSupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
JettyCometSupport.service(AtmosphereRequest req,
AtmosphereResponse response) |
Action |
JettyAsyncSupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Jetty9AsyncSupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Jetty7CometSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
JBossWebCometSupport.service(AtmosphereRequest req,
AtmosphereResponse res)
Invoked by the Tomcat AIO when a Comet request gets detected.
|
Action |
JBossAsyncSupportWithWebSocket.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
GrizzlyServlet30WebSocketSupport.service(AtmosphereRequest request,
AtmosphereResponse response) |
Action |
GrizzlyCometSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Grizzly2WebSocketSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
Grizzly2CometSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
GlassFishv2CometSupport.service(AtmosphereRequest req,
AtmosphereResponse res)
|
Action |
GlassFishWebSocketSupport.service(AtmosphereRequest request,
AtmosphereResponse response) |
Action |
GlassFishServlet30WebSocketSupport.service(AtmosphereRequest request,
AtmosphereResponse response) |
Action |
GlassFishServ30WebSocketSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
Action |
BlockingIOCometSupport.service(AtmosphereRequest req,
AtmosphereResponse res) |
protected void |
BlockingIOCometSupport.suspend(Action action,
AtmosphereRequest req,
AtmosphereResponse res)
Suspend the connection by blocking the current
Thread |
Action |
TomcatWebSocketUtil.Delegate.suspended(AtmosphereRequest request,
AtmosphereResponse response) |
Constructor and Description |
---|
JettyWebSocketHandler(AtmosphereRequest request,
AtmosphereFramework framework,
WebSocketProcessor webSocketProcessor) |
TomcatWebSocketHandler(AtmosphereRequest request,
AtmosphereFramework framework,
WebSocketProcessor webSocketProcessor) |
Modifier and Type | Class and Description |
---|---|
class |
AtmosphereRequestImpl
An Atmosphere request representation.
|
Modifier and Type | Method and Description |
---|---|
AtmosphereRequest |
AtmosphereRequestImpl.body(byte[] bytes) |
AtmosphereRequest |
AtmosphereRequest.body(byte[] bytes) |
AtmosphereRequest |
AtmosphereRequestImpl.body(InputStream body) |
AtmosphereRequest |
AtmosphereRequest.body(InputStream body) |
AtmosphereRequest |
AtmosphereRequestImpl.body(Reader body) |
AtmosphereRequest |
AtmosphereRequest.body(Reader body) |
AtmosphereRequest |
AtmosphereRequestImpl.body(String body) |
AtmosphereRequest |
AtmosphereRequest.body(String body) |
AtmosphereRequest |
AtmosphereRequestImpl.Builder.build() |
AtmosphereRequest |
AtmosphereRequest.Builder.build() |
static AtmosphereRequest |
AtmosphereRequestImpl.cloneRequest(javax.servlet.http.HttpServletRequest request,
boolean loadInMemory,
boolean copySession,
boolean isDestroyable,
boolean createSession)
Copy the HttpServletRequest content inside an AtmosphereRequest.
|
AtmosphereRequest |
AtmosphereRequestImpl.contentType(String m) |
AtmosphereRequest |
AtmosphereRequest.contentType(String m) |
AtmosphereRequest |
AtmosphereRequestImpl.contextPath(String contextPath) |
AtmosphereRequest |
AtmosphereRequest.contextPath(String contextPath) |
AtmosphereRequest |
AtmosphereRequestImpl.destroyable(boolean destroyable) |
AtmosphereRequest |
AtmosphereRequest.destroyable(boolean destroyable) |
AtmosphereRequest |
AtmosphereResourceImpl.getRequest() |
AtmosphereRequest |
AtmosphereResource.getRequest()
Return the underlying
AtmosphereRequest request. |
AtmosphereRequest |
AtmosphereResourceImpl.getRequest(boolean enforceScope) |
AtmosphereRequest |
AtmosphereRequestImpl.header(String name,
String value) |
AtmosphereRequest |
AtmosphereRequest.header(String name,
String value)
Add a header.
|
AtmosphereRequest |
AtmosphereRequestImpl.headers(Map<String,String> headers) |
AtmosphereRequest |
AtmosphereRequest.headers(Map<String,String> headers)
Add all headers contained within the Map.
|
AtmosphereRequest |
AtmosphereRequestImpl.method(String m) |
AtmosphereRequest |
AtmosphereRequest.method(String m) |
static AtmosphereRequest |
AtmosphereRequestImpl.newInstance()
Create an instance of this class without an associated
HttpServletRequest . |
AtmosphereRequest |
AtmosphereRequestImpl.pathInfo(String pathInfo) |
AtmosphereRequest |
AtmosphereRequest.pathInfo(String pathInfo) |
AtmosphereRequest |
AtmosphereRequestImpl.queryString(String qs) |
AtmosphereRequest |
AtmosphereRequest.queryString(String qs)
Set the query string.
|
AtmosphereRequest |
AtmosphereResponseImpl.request() |
AtmosphereRequest |
AtmosphereResponse.request()
Return the associated
AtmosphereRequest . |
AtmosphereRequest |
AtmosphereRequestImpl.requestURI(String requestURI) |
AtmosphereRequest |
AtmosphereRequest.requestURI(String requestURI) |
AtmosphereRequest |
AtmosphereRequestImpl.servletPath(String servletPath) |
AtmosphereRequest |
AtmosphereRequest.servletPath(String servletPath) |
static AtmosphereRequest |
AtmosphereRequestImpl.wrap(javax.servlet.http.HttpServletRequest request)
Wrap an
HttpServletRequest . |
Modifier and Type | Method and Description |
---|---|
Action |
AsynchronousProcessor.cancelled(AtmosphereRequest req,
AtmosphereResponse res)
All proprietary Comet based
Servlet must invoke the cancelled method when the underlying WebServer
detect that the client closed the connection. |
protected Map<String,String> |
AtmosphereFramework.configureQueryStringAsRequest(AtmosphereRequest request) |
AtmosphereFramework |
AtmosphereFramework.configureRequestResponse(AtmosphereRequest req,
AtmosphereResponse res)
Configure some attributes on the
AtmosphereRequest . |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a)
Create an
AtmosphereResourceImpl |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a)
Create an
AtmosphereResourceImpl |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler,
AtmosphereResource.TRANSPORT t)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler,
AtmosphereResource.TRANSPORT t)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
String uuid,
AtmosphereRequest request)
Create an
AtmosphereResource associated with the uuid. |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
String uuid,
AtmosphereRequest request)
Create an
AtmosphereResource associated with the uuid. |
Action |
AtmosphereFramework.doCometSupport(AtmosphereRequest req,
AtmosphereResponse res)
Invoke the proprietary
AsyncSupport . |
AtmosphereResource |
AtmosphereResourceImpl.initialize(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest req,
AtmosphereResponse response,
AsyncSupport asyncSupport,
AtmosphereHandler atmosphereHandler)
Initialize an
AtmosphereResource . |
AtmosphereResource |
AtmosphereResource.initialize(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest req,
AtmosphereResponse response,
AsyncSupport asyncSupport,
AtmosphereHandler atmosphereHandler)
Initialize an
AtmosphereResource . |
protected AtmosphereFramework.AtmosphereHandlerWrapper |
AsynchronousProcessor.map(AtmosphereRequest req)
Return the
AtmosphereHandler mapped to the passed servlet-path. |
static AtmosphereResponse |
AtmosphereResponseImpl.newInstance(AtmosphereConfig config,
AtmosphereRequest request,
WebSocket webSocket)
Create a new instance to use with WebSocket.
|
static AtmosphereResponse |
AtmosphereResponseImpl.newInstance(AtmosphereRequest request)
Create a new instance to use with WebSocket.
|
AtmosphereFramework |
AtmosphereFramework.notify(Action.TYPE type,
AtmosphereRequest request,
AtmosphereResponse response) |
void |
AsyncSupportListenerAdapter.onClose(AtmosphereRequest request,
AtmosphereResponse response) |
void |
AsyncSupportListener.onClose(AtmosphereRequest request,
AtmosphereResponse response)
Invoked when an
AtmosphereResource gets closed. |
void |
AsyncSupportListenerAdapter.onDestroyed(AtmosphereRequest request,
AtmosphereResponse response) |
void |
AsyncSupportListener.onDestroyed(AtmosphereRequest request,
AtmosphereResponse response)
Invoked when an
AtmosphereResource gets destroyed. |
void |
AsyncSupportListenerAdapter.onResume(AtmosphereRequest request,
AtmosphereResponse response) |
void |
AsyncSupportListener.onResume(AtmosphereRequest request,
AtmosphereResponse response)
Invoked when an
AtmosphereResource gets resumed. |
void |
AsyncSupportListenerAdapter.onSuspend(AtmosphereRequest request,
AtmosphereResponse response) |
void |
AsyncSupportListener.onSuspend(AtmosphereRequest request,
AtmosphereResponse response)
Invoked when an
AtmosphereResource gets suspended. |
void |
AsyncSupportListenerAdapter.onTimeout(AtmosphereRequest request,
AtmosphereResponse response) |
void |
AsyncSupportListener.onTimeout(AtmosphereRequest request,
AtmosphereResponse response)
Invoked when an
AtmosphereResource times out. |
AtmosphereResponse |
AtmosphereResponseImpl.request(AtmosphereRequest atmosphereRequest) |
AtmosphereResponseImpl.Builder |
AtmosphereResponseImpl.Builder.request(AtmosphereRequest atmosphereRequest) |
AtmosphereResponse |
AtmosphereResponse.request(AtmosphereRequest atmosphereRequest)
Set the associated
AtmosphereRequest . |
AtmosphereResponse.Builder |
AtmosphereResponse.Builder.request(AtmosphereRequest atmosphereRequest) |
Action |
AsynchronousProcessor.resumed(AtmosphereRequest request,
AtmosphereResponse response)
All proprietary Comet based
Servlet must invoke the resume method when the Atmosphere's application
decide to resume the AtmosphereResponse . |
Action |
AsyncSupport.service(AtmosphereRequest req,
AtmosphereResponse res)
|
Action |
AsynchronousProcessor.suspended(AtmosphereRequest request,
AtmosphereResponse response)
All proprietary Comet based
Servlet must invoke the suspended method when the first request comes in. |
Action |
AsynchronousProcessor.timedout(AtmosphereRequest req,
AtmosphereResponse res)
All proprietary Comet based
Servlet must invoke the timedout method when the underlying WebServer time
out the AtmosphereResponse . |
Constructor and Description |
---|
AtmosphereResourceImpl(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest req,
AtmosphereResponse response,
AsyncSupport asyncSupport,
AtmosphereHandler atmosphereHandler)
Deprecated.
|
AtmosphereResponseImpl(AsyncIOWriter asyncIOWriter,
AtmosphereRequest atmosphereRequest,
boolean destroyable) |
AtmosphereResponseImpl(javax.servlet.http.HttpServletResponse r,
AsyncIOWriter asyncIOWriter,
AtmosphereRequest atmosphereRequest,
boolean destroyable) |
Modifier and Type | Method and Description |
---|---|
AtmosphereRequest |
AtmosphereRequestIntrospector.injectable(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
protected AtmosphereRequest |
SimpleRestInterceptor.createAtmosphereRequest(AtmosphereRequest request,
String body) |
Modifier and Type | Method and Description |
---|---|
HeartbeatInterceptor |
HeartbeatInterceptor.clock(int interval,
AtmosphereResource r,
AtmosphereRequest request,
AtmosphereResponse response)
Configures the heartbeat sent by the server in an interval in seconds specified in parameter for the given
resource.
|
protected AtmosphereRequest |
SimpleRestInterceptor.createAtmosphereRequest(AtmosphereRequest request,
String body) |
protected boolean |
SimpleRestInterceptor.isDetached(AtmosphereRequest request) |
protected static boolean |
SimpleRestInterceptor.isLastResponse(AtmosphereRequest request,
AtmosphereResponse response) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Utils.atmosphereProtocol(AtmosphereRequest r) |
String |
DefaultEndpointMapper.computePath(AtmosphereRequest req) |
static void |
Utils.destroyMeteor(AtmosphereRequest req) |
static boolean |
IOUtils.isBodyBinary(AtmosphereRequest request) |
U |
EndpointMapper.map(AtmosphereRequest req,
Map<String,U> handlers)
Mape the request to its associated endpoint.
|
U |
DefaultEndpointMapper.map(AtmosphereRequest req,
Map<String,U> handlers) |
static String |
Utils.pathInfo(AtmosphereRequest request) |
Modifier and Type | Method and Description |
---|---|
List<AtmosphereRequest> |
WebSocketProtocolStream.onBinaryStream(WebSocket webSocket,
InputStream stream)
Parse the WebSocket stream, and delegate the processing to the
AtmosphereFramework.asyncSupport or
to any existing technology. |
List<AtmosphereRequest> |
WebSocketProtocol.onMessage(WebSocket webSocket,
byte[] data,
int offset,
int length)
Parse the WebSocket message, and delegate the processing to the
AtmosphereFramework.asyncSupport or
to any existing technology. |
List<AtmosphereRequest> |
WebSocketProtocol.onMessage(WebSocket webSocket,
String data)
Parse the WebSocket message, and delegate the processing to the
AtmosphereFramework.asyncSupport or
to any existing technology. |
List<AtmosphereRequest> |
WebSocketProtocolStream.onTextStream(WebSocket webSocket,
Reader r)
Parse the WebSocket stream, and delegate the processing to the
AtmosphereFramework.asyncSupport or
to any existing technology. |
Modifier and Type | Method and Description |
---|---|
static Map<String,String> |
DefaultWebSocketProcessor.configureHeader(AtmosphereRequest request) |
void |
DefaultWebSocketProcessor.dispatch(WebSocket webSocket,
AtmosphereRequest request,
AtmosphereResponse r)
Dispatch to request/response to the
AsyncSupport implementation as it was a normal HTTP request. |
static void |
WebSocket.notSupported(AtmosphereRequest request,
AtmosphereResponse response) |
void |
WebSocketProcessorAdapter.open(WebSocket webSocket,
AtmosphereRequest request,
AtmosphereResponse response) |
void |
WebSocketProcessor.open(WebSocket webSocket,
AtmosphereRequest request,
AtmosphereResponse response)
Invoked when a WebSocket gets opened by the underlying container
|
void |
DefaultWebSocketProcessor.open(WebSocket webSocket,
AtmosphereRequest request,
AtmosphereResponse response) |
protected WebSocketHandler |
DefaultWebSocketProcessor.postProcessMapping(WebSocket webSocket,
AtmosphereRequest request,
WebSocketProcessor.WebSocketHandlerProxy w) |
Modifier and Type | Method and Description |
---|---|
List<AtmosphereRequest> |
StreamingHttpProtocol.onBinaryStream(WebSocket webSocket,
InputStream stream) |
List<AtmosphereRequest> |
StreamingHttpProtocol.onMessage(WebSocket webSocket,
byte[] data,
int offset,
int length) |
List<AtmosphereRequest> |
SimpleHttpProtocol.onMessage(WebSocket webSocket,
byte[] d,
int offset,
int length) |
List<AtmosphereRequest> |
EchoProtocol.onMessage(WebSocket webSocket,
byte[] data,
int offset,
int length) |
List<AtmosphereRequest> |
StreamingHttpProtocol.onMessage(WebSocket webSocket,
String data) |
List<AtmosphereRequest> |
SimpleHttpProtocol.onMessage(WebSocket webSocket,
String message) |
List<AtmosphereRequest> |
EchoProtocol.onMessage(WebSocket webSocket,
String data) |
List<AtmosphereRequest> |
StreamingHttpProtocol.onTextStream(WebSocket webSocket,
Reader r) |
Copyright © 2016. All rights reserved.