Class JsrAnnotatedEventDriver

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

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

org.eclipse.jetty.websocket.jsr356.endpoints.AbstractJsrEventDriver

org.eclipse.jetty.websocket.jsr356.endpoints.JsrAnnotatedEventDriver

All Implemented Interfaces:

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

public class JsrAnnotatedEventDriver
extends AbstractJsrEventDriver

Base implementation for JSR-356 Annotated event drivers.

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
private final JsrEvents<?,?>	events
private static final org.eclipse.jetty.util.log.Logger	LOG

Fields inherited from class AbstractJsrEventDriver

config, jsrsession, metadata

Fields inherited from class 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
JsrAnnotatedEventDriver(WebSocketPolicy policy, EndpointInstance endpointInstance, JsrEvents<?,?> events)

Method Summary

Modifier and Type	Method	Description
void	init(JsrSession jsrsession)
void	onBinaryFrame(ByteBuffer buffer, boolean fin)	Entry point for all incoming binary frames.
void	onBinaryMessage(byte[] data)	Entry point for binary frames destined for MessageHandler.Whole
protected void	onClose(javax.websocket.CloseReason closereason)
void	onConnect()
void	onError(Throwable cause)
private void	onFatalError(Throwable t)
void	onFrame(Frame frame)
void	onInputStream(InputStream stream)
void	onPartialBinaryMessage(ByteBuffer buffer, boolean fin)
void	onPartialTextMessage(String message, boolean fin)
void	onPing(ByteBuffer buffer)
void	onPong(ByteBuffer buffer)
void	onReader(Reader reader)
void	onTextFrame(ByteBuffer buffer, boolean fin)	Entry point for all incoming text frames.
void	onTextMessage(String message)	Entry point for whole text messages
void	setPathParameters(Map<String,String> pathParameters)
String	toString()

Methods inherited from class AbstractJsrEventDriver

getConfig, getJsrSession, getMetadata, onClose, openSession, setEndpointconfig

Methods inherited from class AbstractEventDriver

appendMessage, dispatch, getBatchMode, getPolicy, getSession, incomingFrame, onContinuationFrame

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 Object

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

Field Details

LOG

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

events

private final JsrEvents<?,?> events

Constructor Details

JsrAnnotatedEventDriver

public JsrAnnotatedEventDriver(WebSocketPolicy policy,
 EndpointInstance endpointInstance,
 JsrEvents<?,?> events)

Method Details

init

public void init(JsrSession jsrsession)

Specified by:

init in class AbstractJsrEventDriver

onBinaryFrame

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

Entry point for all incoming binary frames.

Throws:

IOException

onBinaryMessage

public void onBinaryMessage(byte[] data)

Entry point for binary frames destined for MessageHandler.Whole

onClose

protected void onClose(javax.websocket.CloseReason closereason)

Specified by:

onClose in class AbstractJsrEventDriver

onConnect

public void onConnect()

onError

public void onError(Throwable cause)

onFatalError

private void onFatalError(Throwable t)

onFrame

public void onFrame(Frame frame)

Specified by:

onFrame in interface EventDriver

Overrides:

onFrame in class AbstractJsrEventDriver

onInputStream

public void onInputStream(InputStream stream)
                   throws IOException

Throws:

IOException

onPartialBinaryMessage

public void onPartialBinaryMessage(ByteBuffer buffer,
 boolean fin)

onPartialTextMessage

public void onPartialTextMessage(String message,
 boolean fin)

onPing

public void onPing(ByteBuffer buffer)

Specified by:

onPing in interface EventDriver

Overrides:

onPing in class AbstractEventDriver

onPong

public void onPong(ByteBuffer buffer)

Specified by:

onPong in interface EventDriver

Overrides:

onPong in class AbstractEventDriver

onReader

public void onReader(Reader reader)
              throws IOException

Throws:

IOException

onTextFrame

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

Entry point for all incoming text frames.

Throws:

IOException

onTextMessage

public void onTextMessage(String message)

Entry point for whole text messages

setPathParameters

public void setPathParameters(Map<String,String> pathParameters)

Specified by:

setPathParameters in class AbstractJsrEventDriver

toString

public String toString()

Overrides:

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