public class JettyListenerEventDriver extends AbstractEventDriver
WebSocketListener
based User WebSocket implementations.AbstractLifeCycle.AbstractLifeCycleListener
LifeCycle.Listener
Modifier and Type | Field and Description |
---|---|
private boolean |
hasCloseBeenCalled |
private WebSocketConnectionListener |
listener |
private static Logger |
LOG |
private Utf8PartialBuilder |
utf8Partial |
activeMessage, policy, session, TARGET_LOG, websocket
Constructor and Description |
---|
JettyListenerEventDriver(WebSocketPolicy policy,
WebSocketConnectionListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
onBinaryFrame(java.nio.ByteBuffer buffer,
boolean fin) |
void |
onBinaryMessage(byte[] data) |
void |
onClose(CloseInfo close) |
void |
onConnect() |
void |
onError(java.lang.Throwable cause) |
void |
onFrame(Frame frame) |
void |
onInputStream(java.io.InputStream stream) |
void |
onReader(java.io.Reader reader) |
void |
onTextFrame(java.nio.ByteBuffer buffer,
boolean fin) |
void |
onTextMessage(java.lang.String message)
Whole Message event.
|
java.lang.String |
toString() |
appendMessage, dispatch, getBatchMode, getPolicy, getSession, incomingFrame, onContinuationFrame, onPing, onPong, openSession
addLifeCycleListener, doStart, doStop, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop
private static final Logger LOG
private final WebSocketConnectionListener listener
private Utf8PartialBuilder utf8Partial
private boolean hasCloseBeenCalled
public JettyListenerEventDriver(WebSocketPolicy policy, WebSocketConnectionListener listener)
public void onBinaryFrame(java.nio.ByteBuffer buffer, boolean fin) throws java.io.IOException
java.io.IOException
public void onBinaryMessage(byte[] data)
public void onClose(CloseInfo close)
public void onConnect()
public void onError(java.lang.Throwable cause)
public void onFrame(Frame frame)
public void onInputStream(java.io.InputStream stream)
public void onReader(java.io.Reader reader)
public void onTextFrame(java.nio.ByteBuffer buffer, boolean fin) throws java.io.IOException
java.io.IOException
public void onTextMessage(java.lang.String message)
message
- the whole messagepublic java.lang.String toString()
toString
in class AbstractLifeCycle