org.cauli.server.handler

类 ReconnectingWebSocketHandler

java.lang.Object

org.cauli.server.handler.ReconnectingWebSocketHandler

所有已实现的接口:

WebSocketHandler

public class ReconnectingWebSocketHandler
extends Object
implements WebSocketHandler

字段概要

字段

限定符和类型	字段和说明
private AtomicBoolean	connected
private WebSocketHandler	handler
private long	reconnectIntervalMillis
private Timer	timer
private WebSocket	webSocket

构造器概要

构造器

构造器和说明
ReconnectingWebSocketHandler(WebSocketHandler handler, WebSocket webSocket, long reconnectIntervalMillis)

方法概要

方法

限定符和类型	方法和说明
void	onClose(WebSocketConnection connection) Called when a connection is closed.
void	onMessage(WebSocketConnection connection, byte[] msg)
void	onMessage(WebSocketConnection connection, String msg)
void	onOpen(WebSocketConnection connection)
void	onPing(WebSocketConnection connection, byte[] msg)
void	onPong(WebSocketConnection connection, byte[] msg)
private void	scheduleReconnect()

从类继承的方法 java.lang.Object

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

字段详细资料

handler

private final WebSocketHandler handler

webSocket

private final WebSocket webSocket

reconnectIntervalMillis

private final long reconnectIntervalMillis

timer

private final Timer timer

connected

private final AtomicBoolean connected

构造器详细资料

ReconnectingWebSocketHandler

public ReconnectingWebSocketHandler(WebSocketHandler handler,
                            WebSocket webSocket,
                            long reconnectIntervalMillis)

方法详细资料

onOpen

public void onOpen(WebSocketConnection connection)
            throws Throwable

指定者:

onOpen 在接口中 WebSocketHandler

抛出:

Throwable

onClose

public void onClose(WebSocketConnection connection)
             throws Throwable

从接口复制的说明: WebSocketHandler

Called when a connection is closed.

指定者:

onClose 在接口中 WebSocketHandler

参数:

connection - the connection that was closed. Beware that the connection will be null if this handler is used in a WebSocket that fails to connect.

抛出:

Exception

Throwable

onMessage

public void onMessage(WebSocketConnection connection,
             String msg)
               throws Throwable

指定者:

onMessage 在接口中 WebSocketHandler

抛出:

Throwable

onMessage

public void onMessage(WebSocketConnection connection,
             byte[] msg)
               throws Throwable

指定者:

onMessage 在接口中 WebSocketHandler

抛出:

Throwable

onPing

public void onPing(WebSocketConnection connection,
          byte[] msg)
            throws Throwable

指定者:

onPing 在接口中 WebSocketHandler

抛出:

Throwable

onPong

public void onPong(WebSocketConnection connection,
          byte[] msg)
            throws Throwable

指定者:

onPong 在接口中 WebSocketHandler

抛出:

Throwable

scheduleReconnect

private void scheduleReconnect()