Package org.apache.camel.component.atmosphere.websocket

Class WebsocketHandler

java.lang.Object

org.apache.camel.component.atmosphere.websocket.WebsocketHandler

All Implemented Interfaces:

org.atmosphere.inject.AtmosphereConfigAware, org.atmosphere.websocket.WebSocketProtocol

Direct Known Subclasses:

WebsocketStreamHandler

public class WebsocketHandler
extends Object
implements org.atmosphere.websocket.WebSocketProtocol

Field Summary

Fields

Modifier and Type	Field	Description
protected WebsocketConsumer	consumer
protected WebSocketStore	store

Constructor Summary

Constructors

Constructor	Description
WebsocketHandler()

Method Summary

Modifier and Type	Method	Description
void	configure(org.atmosphere.cpr.AtmosphereConfig config)
void	onClose(org.atmosphere.websocket.WebSocket webSocket)
void	onError(org.atmosphere.websocket.WebSocket webSocket, org.atmosphere.websocket.WebSocketProcessor.WebSocketException t)
List<org.atmosphere.cpr.AtmosphereRequest>	onMessage(org.atmosphere.websocket.WebSocket webSocket, byte[] data, int offset, int length)
List<org.atmosphere.cpr.AtmosphereRequest>	onMessage(org.atmosphere.websocket.WebSocket webSocket, String data)
void	onOpen(org.atmosphere.websocket.WebSocket webSocket)
void	setConsumer(WebsocketConsumer consumer)

Methods inherited from class java.lang.Object

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

Field Details

consumer

protected WebsocketConsumer consumer

store

protected WebSocketStore store

Constructor Details

WebsocketHandler

public WebsocketHandler()

Method Details

configure

public void configure(org.atmosphere.cpr.AtmosphereConfig config)

Specified by:

configure in interface org.atmosphere.inject.AtmosphereConfigAware

onClose

public void onClose(org.atmosphere.websocket.WebSocket webSocket)

Specified by:

onClose in interface org.atmosphere.websocket.WebSocketProtocol

onError

public void onError(org.atmosphere.websocket.WebSocket webSocket,
 org.atmosphere.websocket.WebSocketProcessor.WebSocketException t)

Specified by:

onError in interface org.atmosphere.websocket.WebSocketProtocol

onOpen

public void onOpen(org.atmosphere.websocket.WebSocket webSocket)

Specified by:

onOpen in interface org.atmosphere.websocket.WebSocketProtocol

onMessage

public List<org.atmosphere.cpr.AtmosphereRequest> onMessage(org.atmosphere.websocket.WebSocket webSocket,
 String data)

Specified by:

onMessage in interface org.atmosphere.websocket.WebSocketProtocol

onMessage

public List<org.atmosphere.cpr.AtmosphereRequest> onMessage(org.atmosphere.websocket.WebSocket webSocket,
 byte[] data,
 int offset,
 int length)

Specified by:

onMessage in interface org.atmosphere.websocket.WebSocketProtocol

setConsumer

public void setConsumer(WebsocketConsumer consumer)