Package | Description |
---|---|
org.atmosphere.container.version | |
org.atmosphere.cpr | |
org.atmosphere.websocket | |
org.atmosphere.websocket.protocol |
Modifier and Type | Class and Description |
---|---|
class |
Grizzly2WebSocket |
class |
GrizzlyWebSocket |
class |
JBossWebSocket
Adapts a JBoss
WebSocket to an Atmosphere WebSocket . |
class |
Jetty8WebSocket
Jetty 8 WebSocket support.
|
class |
Jetty9WebSocket |
class |
JSR356WebSocket
Asynchronous based
Session websocket |
class |
TomcatWebSocket
Tomcat WebSocket Support
|
class |
WebLogicWebSocket |
Modifier and Type | Method and Description |
---|---|
WebSocket |
TomcatWebSocket.flush(AtmosphereResponse r) |
WebSocket |
Jetty8WebSocket.flush(AtmosphereResponse r) |
WebSocket |
GrizzlyWebSocket.flush(AtmosphereResponse r) |
WebSocket |
WebLogicWebSocket.write(byte[] b,
int offset,
int length) |
WebSocket |
TomcatWebSocket.write(byte[] b,
int offset,
int length) |
WebSocket |
Jetty9WebSocket.write(byte[] b,
int offset,
int length) |
WebSocket |
Jetty8WebSocket.write(byte[] b,
int offset,
int length) |
WebSocket |
JSR356WebSocket.write(byte[] data,
int offset,
int length) |
WebSocket |
JBossWebSocket.write(byte[] b,
int offset,
int length) |
WebSocket |
GrizzlyWebSocket.write(byte[] data,
int offset,
int length) |
WebSocket |
Grizzly2WebSocket.write(byte[] data,
int offset,
int length) |
WebSocket |
WebLogicWebSocket.write(String s) |
WebSocket |
TomcatWebSocket.write(String s) |
WebSocket |
Jetty9WebSocket.write(String s) |
WebSocket |
Jetty8WebSocket.write(String s) |
WebSocket |
JSR356WebSocket.write(String s) |
WebSocket |
JBossWebSocket.write(String s) |
WebSocket |
GrizzlyWebSocket.write(String s) |
WebSocket |
Grizzly2WebSocket.write(String s) |
Modifier and Type | Method and Description |
---|---|
WebSocket |
AtmosphereResourceImpl.webSocket() |
Modifier and Type | Method and Description |
---|---|
static AtmosphereResponse |
AtmosphereResponseImpl.newInstance(AtmosphereConfig config,
AtmosphereRequest request,
WebSocket webSocket)
Create a new instance to use with WebSocket.
|
AtmosphereResourceImpl |
AtmosphereResourceImpl.webSocket(WebSocket webSocket) |
Modifier and Type | Method and Description |
---|---|
WebSocket |
WebSocket.attachment(Object attachment)
Attach an object.
|
WebSocket |
WebSocket.binaryWrite(boolean binaryWrite)
Switch to binary write, or go back to text write.
|
WebSocket |
WebSocket.broadcast(Object o)
Broadcast, using the
AtmosphereResource.getBroadcaster() the object to all
WebSocket associated with the Broadcaster . |
WebSocket |
WebSocketFactory.find(String uuid)
Retrieve the
WebSocket associated with a uuid. |
WebSocket |
DefaultWebSocketFactory.find(String uuid) |
WebSocket |
WebSocket.flush(AtmosphereResponse r) |
WebSocket |
WebSocket.redirect(AtmosphereResponse r,
String location) |
WebSocket |
WebSocket.resource(AtmosphereResource r)
Associate an
AtmosphereResource to this WebSocket |
WebSocket |
WebSocket.sendPing(byte[] payload)
Send a WebSocket Ping
|
WebSocket |
WebSocket.sendPong(byte[] payload)
Send a WebSocket Pong
|
WebSocket |
WebSocket.shiftAttributes()
Copy
AtmosphereRequestImpl.localAttributes() that where set when the websocket was opened. |
WebSocket |
WebSocketEventListener.WebSocketEvent.webSocket()
The WebSocket.
|
protected WebSocket |
WebSocket.webSocketHandler(WebSocketHandler webSocketHandler) |
WebSocket |
WebSocket.write(AtmosphereResponse r,
byte[] data) |
WebSocket |
WebSocket.write(AtmosphereResponse r,
byte[] b,
int offset,
int length) |
WebSocket |
WebSocket.write(AtmosphereResponse r,
String data) |
WebSocket |
WebSocket.write(byte[] b)
Use the underlying container's websocket to write the byte.
|
abstract WebSocket |
WebSocket.write(byte[] b,
int offset,
int length)
Use the underlying container's websocket to write the byte.
|
abstract WebSocket |
WebSocket.write(String s)
Use the underlying container's websocket to write the String.
|
WebSocket |
WebSocket.writeError(AtmosphereResponse r,
int errorCode,
String message) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketProcessorAdapter.close(WebSocket webSocket,
int closeCode) |
void |
WebSocketProcessor.close(WebSocket webSocket,
int closeCode)
Invked when the WebServer is closing the native WebSocket
|
void |
DefaultWebSocketProcessor.close(WebSocket webSocket,
int closeCode) |
void |
DefaultWebSocketProcessor.dispatch(WebSocket webSocket,
AtmosphereRequest request,
AtmosphereResponse r)
Dispatch to request/response to the
AsyncSupport implementation as it was a normal HTTP request. |
protected void |
DefaultWebSocketProcessor.dispatchReader(WebSocket webSocket,
Reader r) |
protected void |
DefaultWebSocketProcessor.dispatchStream(WebSocket webSocket,
InputStream is) |
void |
DefaultWebSocketProcessor.executeClose(WebSocket webSocket,
int closeCode) |
void |
WebSocketProcessorAdapter.invokeWebSocketProtocol(WebSocket webSocket,
byte[] data,
int offset,
int length) |
void |
WebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
byte[] data,
int offset,
int length)
Invoked when a WebSocket message gets received from the underlying container
|
void |
DefaultWebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
byte[] data,
int offset,
int length) |
void |
WebSocketProcessorAdapter.invokeWebSocketProtocol(WebSocket webSocket,
InputStream stream) |
void |
WebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
InputStream stream)
Invoked when a WebSocket message gets received from the underlying container
|
void |
DefaultWebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
InputStream stream) |
void |
WebSocketProcessorAdapter.invokeWebSocketProtocol(WebSocket webSocket,
Reader reader) |
void |
WebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
Reader reader)
Invoked when a WebSocket message gets received from the underlying container
|
void |
DefaultWebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
Reader reader) |
void |
WebSocketProcessorAdapter.invokeWebSocketProtocol(WebSocket webSocket,
String webSocketMessage) |
void |
WebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
String webSocketMessage)
Invoked when a WebSocket message gets received from the underlying container
|
void |
DefaultWebSocketProcessor.invokeWebSocketProtocol(WebSocket webSocket,
String webSocketMessage) |
void |
WebSocketProcessorAdapter.notifyListener(WebSocket webSocket,
WebSocketEventListener.WebSocketEvent webSocketEvent) |
void |
WebSocketProcessor.notifyListener(WebSocket webSocket,
WebSocketEventListener.WebSocketEvent webSocketEvent)
Notify all
WebSocketEventListener |
void |
DefaultWebSocketProcessor.notifyListener(WebSocket webSocket,
WebSocketEventListener.WebSocketEvent event) |
void |
WebSocketStreamingHandlerAdapter.onBinaryStream(WebSocket webSocket,
InputStream inputStream) |
void |
WebSocketStreamingHandler.onBinaryStream(WebSocket webSocket,
InputStream inputStream)
Invoked when a byte message is received.
|
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. |
void |
WebSocketStreamingHandlerAdapter.onByteMessage(WebSocket webSocket,
byte[] data,
int offset,
int length) |
void |
WebSocketProcessor.WebSocketHandlerProxy.onByteMessage(WebSocket webSocket,
byte[] data,
int offset,
int length) |
void |
WebSocketHandlerAdapter.onByteMessage(WebSocket webSocket,
byte[] data,
int offset,
int length) |
void |
WebSocketHandler.onByteMessage(WebSocket webSocket,
byte[] data,
int offset,
int length)
Invoked when a byte message is received.
|
void |
WebSocketStreamingHandlerAdapter.onClose(WebSocket webSocket) |
void |
WebSocketProtocol.onClose(WebSocket webSocket)
Invoked when a WebSocket is closed
|
void |
WebSocketProcessor.WebSocketHandlerProxy.onClose(WebSocket webSocket) |
void |
WebSocketHandlerAdapter.onClose(WebSocket webSocket) |
void |
WebSocketHandler.onClose(WebSocket webSocket)
Invoked when a
WebSocket is closed. |
void |
WebSocketStreamingHandlerAdapter.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t) |
void |
WebSocketProtocol.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t)
Invoked when an error occurs.
|
void |
WebSocketProcessor.WebSocketHandlerProxy.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t) |
void |
WebSocketHandlerAdapter.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t) |
void |
WebSocketHandler.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t)
Invoked when a
WebSocket produces an error. |
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. |
void |
WebSocketStreamingHandlerAdapter.onOpen(WebSocket webSocket) |
void |
WebSocketProtocol.onOpen(WebSocket webSocket)
Invoked when a WebSocket is opened
|
void |
WebSocketProcessor.WebSocketHandlerProxy.onOpen(WebSocket webSocket) |
void |
WebSocketHandlerAdapter.onOpen(WebSocket webSocket) |
void |
WebSocketHandler.onOpen(WebSocket webSocket)
Invoked when a
WebSocket is opened. |
void |
WebSocketPingPongListener.onPing(WebSocket webSocket,
byte[] payload,
int offset,
int length)
Handle WebSocket PING
|
void |
DefaultWebSocketProcessor.onPing(WebSocket webSocket,
byte[] payload,
int offset,
int length) |
void |
WebSocketPingPongListener.onPong(WebSocket webSocket,
byte[] payload,
int offset,
int length)
Handle WebSocket PONG
|
void |
DefaultWebSocketProcessor.onPong(WebSocket webSocket,
byte[] payload,
int offset,
int length) |
void |
WebSocketStreamingHandlerAdapter.onTextMessage(WebSocket webSocket,
String data) |
void |
WebSocketProcessor.WebSocketHandlerProxy.onTextMessage(WebSocket webSocket,
String data) |
void |
WebSocketHandlerAdapter.onTextMessage(WebSocket webSocket,
String data) |
void |
WebSocketHandler.onTextMessage(WebSocket webSocket,
String data)
Invoked when a String message is received
|
void |
WebSocketStreamingHandlerAdapter.onTextStream(WebSocket webSocket,
Reader reader) |
void |
WebSocketStreamingHandler.onTextStream(WebSocket webSocket,
Reader reader)
Invoked when a String message is received
|
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. |
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) |
Constructor and Description |
---|
WebSocketEvent(T message,
WebSocketEventListener.WebSocketEvent.TYPE type,
WebSocket webSocket) |
Modifier and Type | Method and Description |
---|---|
protected static AtmosphereRequestImpl.Builder |
ProtocolUtil.constructRequest(WebSocket webSocket,
String pathInfo,
String requestURI,
String methodType,
String contentType,
boolean destroyable) |
List<AtmosphereRequest> |
StreamingHttpProtocol.onBinaryStream(WebSocket webSocket,
InputStream stream) |
void |
StreamingHttpProtocol.onClose(WebSocket webSocket) |
void |
SimpleHttpProtocol.onClose(WebSocket webSocket) |
void |
EchoProtocol.onClose(WebSocket webSocket) |
void |
StreamingHttpProtocol.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t) |
void |
SimpleHttpProtocol.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t) |
void |
EchoProtocol.onError(WebSocket webSocket,
WebSocketProcessor.WebSocketException t) |
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) |
void |
StreamingHttpProtocol.onOpen(WebSocket webSocket) |
void |
SimpleHttpProtocol.onOpen(WebSocket webSocket) |
void |
EchoProtocol.onOpen(WebSocket webSocket) |
List<AtmosphereRequest> |
StreamingHttpProtocol.onTextStream(WebSocket webSocket,
Reader r) |
Copyright © 2016. All rights reserved.