io.socket.engineio.server

Class JettyWebSocketHandler

java.lang.Object

io.socket.engineio.server.Emitter

io.socket.engineio.server.EngineIoWebSocket

io.socket.engineio.server.JettyWebSocketHandler

All Implemented Interfaces:

org.eclipse.jetty.websocket.api.WebSocketConnectionListener, org.eclipse.jetty.websocket.api.WebSocketListener

public final class JettyWebSocketHandler
extends EngineIoWebSocket
implements org.eclipse.jetty.websocket.api.WebSocketListener

Adapter for Jetty WebSocket implementation.

Nested Class Summary

Nested classes/interfaces inherited from class io.socket.engineio.server.Emitter

Emitter.Listener

Constructor Summary

Constructors

Constructor and Description
JettyWebSocketHandler(EngineIoServer server)

Method Summary

Modifier and Type	Method and Description
void	close() Close the WebSocket.
Map<String,List<String>>	getConnectionHeaders() Get the headers in the initial HTTP request.
Map<String,String>	getQuery() Get the query of the initial HTTP request.
void	onWebSocketBinary(byte[] payload, int offset, int len)
void	onWebSocketClose(int statusCode, String reason)
void	onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session)
void	onWebSocketError(Throwable cause)
void	onWebSocketText(String message)
void	write(byte[] message) Write a byte array to the WebSocket and send to remote client.
void	write(String message) Write a string to the WebSocket and send to remote client.

Methods inherited from class io.socket.engineio.server.Emitter

emit, hasListeners, listeners, off, off, off, on, once

Methods inherited from class java.lang.Object

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

Constructor Detail

JettyWebSocketHandler

public JettyWebSocketHandler(EngineIoServer server)

Method Detail

getQuery

public Map<String,String> getQuery()

Description copied from class: EngineIoWebSocket

Get the query of the initial HTTP request.

Specified by:

getQuery in class EngineIoWebSocket

Returns:

Query parameters of the initial HTTP request.

getConnectionHeaders

public Map<String,List<String>> getConnectionHeaders()

Description copied from class: EngineIoWebSocket

Get the headers in the initial HTTP request.

Specified by:

getConnectionHeaders in class EngineIoWebSocket

Returns:

Headers of the initial HTTP request.

write

public void write(String message)
           throws IOException

Description copied from class: EngineIoWebSocket

Write a string to the WebSocket and send to remote client.

Specified by:

write in class EngineIoWebSocket

Parameters:

message - String payload to send.

Throws:

IOException - On write error.

write

public void write(byte[] message)
           throws IOException

Description copied from class: EngineIoWebSocket

Write a byte array to the WebSocket and send to remote client.

Specified by:

write in class EngineIoWebSocket

Parameters:

message - Binary payload to send.

Throws:

IOException - On write error.

close

public void close()

Description copied from class: EngineIoWebSocket

Close the WebSocket.

Specified by:

close in class EngineIoWebSocket

onWebSocketConnect

public void onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session)

Specified by:

onWebSocketConnect in interface org.eclipse.jetty.websocket.api.WebSocketConnectionListener

onWebSocketClose

public void onWebSocketClose(int statusCode,
                             String reason)

Specified by:

onWebSocketClose in interface org.eclipse.jetty.websocket.api.WebSocketConnectionListener

onWebSocketError

public void onWebSocketError(Throwable cause)

Specified by:

onWebSocketError in interface org.eclipse.jetty.websocket.api.WebSocketConnectionListener

onWebSocketBinary

public void onWebSocketBinary(byte[] payload,
                              int offset,
                              int len)

Specified by:

onWebSocketBinary in interface org.eclipse.jetty.websocket.api.WebSocketListener

onWebSocketText

public void onWebSocketText(String message)

Specified by:

onWebSocketText in interface org.eclipse.jetty.websocket.api.WebSocketListener