Package org.cometd.server.websocket.common

Class AbstractWebSocketEndPoint

java.lang.Object

org.cometd.server.websocket.common.AbstractWebSocketEndPoint

Direct Known Subclasses:

JettyWebSocketEndPoint

public abstract class AbstractWebSocketEndPoint
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractWebSocketEndPoint.Context

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractWebSocketEndPoint(AbstractWebSocketTransport transport, BayeuxContext context)

Method Summary

Modifier and Type	Method	Description
abstract void	close(int code, java.lang.String reason)
protected void	flush(AbstractWebSocketEndPoint.Context context, Promise<java.lang.Void> promise)
void	onClose(int code, java.lang.String reason)
void	onError(java.lang.Throwable failure)
void	onMessage(java.lang.String data, Promise<java.lang.Void> p)
protected abstract void	send(ServerSession session, java.lang.String data, org.eclipse.jetty.util.Callback callback)
java.lang.String	toString()
protected void	writeComplete(AbstractWebSocketEndPoint.Context context, java.util.List<ServerMessage> messages)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractWebSocketEndPoint

protected AbstractWebSocketEndPoint(AbstractWebSocketTransport transport,
                                    BayeuxContext context)

Method Detail

send

protected abstract void send(ServerSession session,
                             java.lang.String data,
                             org.eclipse.jetty.util.Callback callback)

close

public abstract void close(int code,
                           java.lang.String reason)

onMessage

public void onMessage(java.lang.String data,
                      Promise<java.lang.Void> p)

onClose

public void onClose(int code,
                    java.lang.String reason)

onError

public void onError(java.lang.Throwable failure)

flush

protected void flush(AbstractWebSocketEndPoint.Context context,
                     Promise<java.lang.Void> promise)

writeComplete

protected void writeComplete(AbstractWebSocketEndPoint.Context context,
                             java.util.List<ServerMessage> messages)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object