org.granite.gravity.jetty8
Class JettyWebSocketChannel

java.lang.Object
  org.granite.gravity.AbstractChannel
      org.granite.gravity.jetty8.JettyWebSocketChannel

All Implemented Interfaces:

org.eclipse.jetty.websocket.WebSocket, org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage, Channel

public class JettyWebSocketChannel
extends AbstractChannel
implements org.eclipse.jetty.websocket.WebSocket, org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.websocket.WebSocket

org.eclipse.jetty.websocket.WebSocket.Connection, org.eclipse.jetty.websocket.WebSocket.FrameConnection, org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage, org.eclipse.jetty.websocket.WebSocket.OnControl, org.eclipse.jetty.websocket.WebSocket.OnFrame, org.eclipse.jetty.websocket.WebSocket.OnTextMessage

Field Summary

Fields inherited from class org.granite.gravity.AbstractChannel

clientType, factory, gravity, id, publishedQueue, publishedQueueLock, publisher, receivedQueue, receivedQueueLock, receiver, sessionId, subscriptions

Constructor Summary

JettyWebSocketChannel(Gravity gravity, String id, JettyWebSocketChannelFactory factory, ServletContext servletContext, String clientType)

Method Summary

protected AsyncHttpContext	acquireAsyncHttpContext()
void	close()
void	destroy()
protected boolean	hasAsyncHttpContext()
void	onClose(int closeCode, String message)
void	onMessage(byte[] data, int offset, int length)
void	onOpen(org.eclipse.jetty.websocket.WebSocket.Connection connection)
protected void	releaseAsyncHttpContext(AsyncHttpContext context)
boolean	runReceived(AsyncHttpContext asyncHttpContext)
void	setConnectAckMessage(Message ackMessage)

Methods inherited from class org.granite.gravity.AbstractChannel

addSubscription, equals, getClientType, getFactory, getGravity, getId, getSerializerContentType, getSubscriptions, hashCode, hasPublishedMessage, hasReceivedMessage, newSerializer, publish, queueReceiver, receive, removeSubscription, runPublish, runReceive, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

JettyWebSocketChannel

public JettyWebSocketChannel(Gravity gravity,
                             String id,
                             JettyWebSocketChannelFactory factory,
                             ServletContext servletContext,
                             String clientType)

Method Detail

setConnectAckMessage

public void setConnectAckMessage(Message ackMessage)

onOpen

public void onOpen(org.eclipse.jetty.websocket.WebSocket.Connection connection)

Specified by:

onOpen in interface org.eclipse.jetty.websocket.WebSocket

onClose

public void onClose(int closeCode,
                    String message)

Specified by:

onClose in interface org.eclipse.jetty.websocket.WebSocket

onMessage

public void onMessage(byte[] data,
                      int offset,
                      int length)

Specified by:

onMessage in interface org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage

runReceived

public boolean runReceived(AsyncHttpContext asyncHttpContext)

Specified by:

runReceived in interface Channel

Overrides:

runReceived in class AbstractChannel

destroy

public void destroy()

Specified by:

destroy in interface Channel

Overrides:

destroy in class AbstractChannel

close

public void close()

Specified by:

close in interface Channel

hasAsyncHttpContext

protected boolean hasAsyncHttpContext()

Specified by:

hasAsyncHttpContext in class AbstractChannel

releaseAsyncHttpContext

protected void releaseAsyncHttpContext(AsyncHttpContext context)

Specified by:

releaseAsyncHttpContext in class AbstractChannel

acquireAsyncHttpContext

protected AsyncHttpContext acquireAsyncHttpContext()

Specified by:

acquireAsyncHttpContext in class AbstractChannel