org.eclipse.jetty.websocket.common.events

Class AbstractEventDriver

java.lang.Object

org.eclipse.jetty.websocket.common.events.AbstractEventDriver

All Implemented Interfaces:

IncomingFrames, EventDriver

Direct Known Subclasses:

AbstractJsrEventDriver, JettyAnnotatedEventDriver, JettyListenerEventDriver

public abstract class AbstractEventDriver
extends Object
implements IncomingFrames, EventDriver

EventDriver is the main interface between the User's WebSocket POJO and the internal jetty implementation of WebSocket.

Field Summary

Fields

Modifier and Type	Field and Description
protected MessageAppender	activeMessage
protected WebSocketPolicy	policy
protected WebSocketSession	session
protected Logger	TARGET_LOG
protected Object	websocket

Constructor Summary

Constructors

Constructor and Description
AbstractEventDriver(WebSocketPolicy policy, Object websocket)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	appendMessage(ByteBuffer buffer, boolean fin)
protected void	dispatch(Runnable runnable)
WebSocketPolicy	getPolicy()
WebSocketSession	getSession()
void	incomingError(Throwable e)
void	incomingFrame(Frame frame) Process the incoming frame.
void	onContinuationFrame(ByteBuffer buffer, boolean fin)
void	onPing(ByteBuffer buffer)
void	onPong(ByteBuffer buffer)
void	openSession(WebSocketSession session)
protected void	terminateConnection(int statusCode, String rawreason)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.websocket.common.events.EventDriver

onBinaryFrame, onBinaryMessage, onClose, onConnect, onError, onFrame, onInputStream, onReader, onTextFrame, onTextMessage

Field Detail

TARGET_LOG

protected final Logger TARGET_LOG

policy

protected final WebSocketPolicy policy

websocket

protected final Object websocket

session

protected WebSocketSession session

activeMessage

protected MessageAppender activeMessage

Constructor Detail

AbstractEventDriver

public AbstractEventDriver(WebSocketPolicy policy,
                   Object websocket)

Method Detail

appendMessage

protected void appendMessage(ByteBuffer buffer,
                 boolean fin)
                      throws IOException

Throws:

IOException

dispatch

protected void dispatch(Runnable runnable)

getPolicy

public WebSocketPolicy getPolicy()

Specified by:

getPolicy in interface EventDriver

getSession

public WebSocketSession getSession()

Specified by:

getSession in interface EventDriver

incomingError

public final void incomingError(Throwable e)

Specified by:

incomingError in interface IncomingFrames

incomingFrame

public void incomingFrame(Frame frame)

Description copied from interface: IncomingFrames

Process the incoming frame.

Note: if you need to hang onto any information from the frame, be sure to copy it, as the information contained in the Frame will be released and/or reused by the implementation.

Specified by:

incomingFrame in interface IncomingFrames

Parameters:

frame - the frame to process

onContinuationFrame

public void onContinuationFrame(ByteBuffer buffer,
                       boolean fin)
                         throws IOException

Specified by:

onContinuationFrame in interface EventDriver

Throws:

IOException

onPong

public void onPong(ByteBuffer buffer)

Specified by:

onPong in interface EventDriver

onPing

public void onPing(ByteBuffer buffer)

Specified by:

onPing in interface EventDriver

openSession

public void openSession(WebSocketSession session)

Specified by:

openSession in interface EventDriver

terminateConnection

protected void terminateConnection(int statusCode,
                       String rawreason)