org.atmosphere.nettosphere

Class NettyWebSocket

java.lang.Object

org.atmosphere.cpr.AsyncIOWriterAdapter

org.atmosphere.cpr.AtmosphereInterceptorWriter

org.atmosphere.websocket.WebSocket

org.atmosphere.nettosphere.NettyWebSocket

All Implemented Interfaces:

org.atmosphere.cpr.AsyncIOWriter, org.atmosphere.cpr.KeepOpenStreamAware

public class NettyWebSocket
extends org.atmosphere.websocket.WebSocket

Field Summary

Fields inherited from class org.atmosphere.websocket.WebSocket

bb, cb, CLEAN_CLOSE, lastWrite, NOT_SUPPORTED, uuid, WEBSOCKET_ACCEPT_DONE, WEBSOCKET_INITIATED, WEBSOCKET_RESUME, WEBSOCKET_SUSPEND

Fields inherited from class org.atmosphere.cpr.AtmosphereInterceptorWriter

filters, reversedFilters

Constructor Summary

Constructors

Constructor and Description
NettyWebSocket(io.netty.channel.Channel channel, org.atmosphere.cpr.AtmosphereConfig config, boolean noInternalAlloc, boolean binaryWrite, int maxFrameSize)

Method Summary

Modifier and Type	Method and Description
java.lang.String	address() The remote ip address.
void	close()
void	close(int statusCode, java.lang.String reasonText)
protected java.util.concurrent.Future<?>	closeFuture()
protected org.atmosphere.websocket.WebSocket	closeFuture(java.util.concurrent.Future<?> closeFuture)
io.netty.channel.ChannelId	id()
boolean	isOpen()
org.atmosphere.websocket.WebSocket	resource(org.atmosphere.cpr.AtmosphereResource r)
org.atmosphere.websocket.WebSocket	sendPing(byte[] payload) Send a WebSocket Ping
org.atmosphere.websocket.WebSocket	sendPong(byte[] payload) Send a WebSocket Pong
org.atmosphere.websocket.WebSocket	write(byte[] data)
org.atmosphere.websocket.WebSocket	write(byte[] data, int offset, int length)
org.atmosphere.websocket.WebSocket	write(java.lang.String data)

Methods inherited from class org.atmosphere.websocket.WebSocket

attachment, attachment, attributes, binaryWrite, broadcast, close, config, flush, lastWriteTimeStampInMilliseconds, notSupported, redirect, resource, shiftAttributes, transform, transform, uuid, webSocketHandler, webSocketHandler, write, write, write, writeError

Methods inherited from class org.atmosphere.cpr.AtmosphereInterceptorWriter

filters, interceptor, interceptor, invokeInterceptor, writeReady

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyWebSocket

public NettyWebSocket(io.netty.channel.Channel channel,
                      org.atmosphere.cpr.AtmosphereConfig config,
                      boolean noInternalAlloc,
                      boolean binaryWrite,
                      int maxFrameSize)

Method Detail

resource

public org.atmosphere.websocket.WebSocket resource(org.atmosphere.cpr.AtmosphereResource r)

Overrides:

resource in class org.atmosphere.websocket.WebSocket

write

public org.atmosphere.websocket.WebSocket write(java.lang.String data)
                                         throws java.io.IOException

Specified by:

write in class org.atmosphere.websocket.WebSocket

Throws:

java.io.IOException

write

public org.atmosphere.websocket.WebSocket write(byte[] data)
                                         throws java.io.IOException

Overrides:

write in class org.atmosphere.websocket.WebSocket

Throws:

java.io.IOException

write

public org.atmosphere.websocket.WebSocket write(byte[] data,
                                                int offset,
                                                int length)
                                         throws java.io.IOException

Specified by:

write in class org.atmosphere.websocket.WebSocket

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in class org.atmosphere.websocket.WebSocket

close

public void close()

Specified by:

close in class org.atmosphere.websocket.WebSocket

close

public void close(int statusCode,
                  java.lang.String reasonText)

Overrides:

close in class org.atmosphere.websocket.WebSocket

sendPing

public org.atmosphere.websocket.WebSocket sendPing(byte[] payload)

Send a WebSocket Ping

Overrides:

sendPing in class org.atmosphere.websocket.WebSocket

Parameters:

payload - the bytes to send

Returns:

this

sendPong

public org.atmosphere.websocket.WebSocket sendPong(byte[] payload)

Send a WebSocket Pong

Overrides:

sendPong in class org.atmosphere.websocket.WebSocket

Parameters:

payload - the bytes to send

Returns:

this

address

public java.lang.String address()

The remote ip address.

Returns:

The remote ip address.

closeFuture

protected org.atmosphere.websocket.WebSocket closeFuture(java.util.concurrent.Future<?> closeFuture)

closeFuture

protected java.util.concurrent.Future<?> closeFuture()

id

public io.netty.channel.ChannelId id()