Class AbstractEventDriver

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

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

All Implemented Interfaces:

org.eclipse.jetty.util.component.LifeCycle, IncomingFrames, EventDriver

Direct Known Subclasses:

AbstractJsrEventDriver, JettyAnnotatedEventDriver, JettyListenerEventDriver

public abstract class AbstractEventDriver
extends org.eclipse.jetty.util.component.AbstractLifeCycle
implements IncomingFrames, EventDriver

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

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

org.eclipse.jetty.util.component.LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
protected MessageAppender	activeMessage
private final org.eclipse.jetty.util.log.Logger	logger
protected WebSocketPolicy	policy
protected WebSocketSession	session
protected final org.eclipse.jetty.util.log.Logger	targetLog
protected final Object	websocket

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor	Description
AbstractEventDriver(WebSocketPolicy policy, Object websocket)

Method Summary

Modifier and Type	Method	Description
protected void	appendMessage(ByteBuffer buffer, boolean fin)
protected void	dispatch(Runnable runnable)
BatchMode	getBatchMode()
WebSocketPolicy	getPolicy()
WebSocketSession	getSession()
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)

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, doStart, doStop, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop, toString

Methods inherited from class Object

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

Methods inherited from interface EventDriver

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

Field Details

logger

private final org.eclipse.jetty.util.log.Logger logger

targetLog

protected final org.eclipse.jetty.util.log.Logger targetLog

policy

protected WebSocketPolicy policy

websocket

protected final Object websocket

session

protected WebSocketSession session

activeMessage

protected MessageAppender activeMessage

Constructor Details

AbstractEventDriver

public AbstractEventDriver(WebSocketPolicy policy,
 Object websocket)

Method Details

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

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

getBatchMode

public BatchMode getBatchMode()

Specified by:

getBatchMode in interface EventDriver

openSession

public void openSession(WebSocketSession session)

Specified by:

openSession in interface EventDriver