Package org.eclipse.jetty.websocket.common.events

Class JettyListenerEventDriver

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

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

org.eclipse.jetty.websocket.common.events.JettyListenerEventDriver

All Implemented Interfaces:

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

public class JettyListenerEventDriver
extends AbstractEventDriver

Handler for WebSocketListener based User WebSocket implementations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	JettyListenerEventDriver.PartialMode

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
private boolean	hasCloseBeenCalled
private final WebSocketConnectionListener	listener
private static final org.eclipse.jetty.util.log.Logger	LOG
private JettyListenerEventDriver.PartialMode	partialMode
private org.eclipse.jetty.util.Utf8StringBuilder	utf8Partial

Fields inherited from class org.eclipse.jetty.websocket.common.events.AbstractEventDriver

activeMessage, policy, session, targetLog, websocket

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

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor	Description
JettyListenerEventDriver(WebSocketPolicy policy, WebSocketConnectionListener listener)

Method Summary

Modifier and Type	Method	Description
void	onBinaryFrame(ByteBuffer buffer, boolean fin)
void	onBinaryMessage(byte[] data)
void	onClose(CloseInfo close)
void	onConnect()
void	onContinuationFrame(ByteBuffer buffer, boolean fin)
void	onError(Throwable cause)
void	onFrame(Frame frame)
void	onInputStream(InputStream stream)
void	onReader(Reader reader)
void	onTextFrame(ByteBuffer buffer, boolean fin)
void	onTextMessage(String message)	Whole Message event.
String	toString()

Methods inherited from class org.eclipse.jetty.websocket.common.events.AbstractEventDriver

appendMessage, dispatch, getBatchMode, getPolicy, getSession, incomingFrame, onPing, onPong, openSession

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

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.eclipse.jetty.util.log.Logger LOG

listener

private final WebSocketConnectionListener listener

utf8Partial

private org.eclipse.jetty.util.Utf8StringBuilder utf8Partial

partialMode

private JettyListenerEventDriver.PartialMode partialMode

hasCloseBeenCalled

private boolean hasCloseBeenCalled

Constructor Details

JettyListenerEventDriver

public JettyListenerEventDriver(WebSocketPolicy policy,
 WebSocketConnectionListener listener)

Method Details

onBinaryFrame

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

Throws:

IOException

onBinaryMessage

public void onBinaryMessage(byte[] data)

onClose

public void onClose(CloseInfo close)

onConnect

public void onConnect()

onError

public void onError(Throwable cause)

onFrame

public void onFrame(Frame frame)

onInputStream

public void onInputStream(InputStream stream)

onReader

public void onReader(Reader reader)

onTextFrame

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

Throws:

IOException

onTextMessage

public void onTextMessage(String message)

Whole Message event.

Parameters:

message - the whole message

onContinuationFrame

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

Specified by:

onContinuationFrame in interface EventDriver

Overrides:

onContinuationFrame in class AbstractEventDriver

Throws:

IOException

toString

public String toString()

Overrides:

toString in class org.eclipse.jetty.util.component.AbstractLifeCycle