org.noear.solon.net.stomp.broker

类 ToStompWebSocketListener

java.lang.Object

org.noear.solon.net.stomp.broker.ToStompWebSocketListener

所有已实现的接口:

SubProtocolCapable, WebSocketListener

public class ToStompWebSocketListener
extends java.lang.Object
implements WebSocketListener, SubProtocolCapable

websocket 转 stomp 监听器

从以下版本开始:

2.7

字段概要

从接口继承的字段 org.noear.solon.net.websocket.SubProtocolCapable

SEC_WEBSOCKET_PROTOCOL

构造器概要

构造器

限定符	构造器和说明
protected	ToStompWebSocketListener(java.lang.String endpoint, StompBrokerMedia brokerMedia)

方法概要

限定符和类型	方法和说明
java.lang.String	getSubProtocols(java.util.Collection<java.lang.String> requestProtocols)
void	onClose(WebSocket socket) 连接关闭时
void	onError(WebSocket socket, java.lang.Throwable error) 出错时
void	onMessage(WebSocket socket, java.nio.ByteBuffer binary) 收到消息时
void	onMessage(WebSocket socket, java.lang.String text) 收到消息时
void	onOpen(WebSocket socket) 连接打开时（可以做个签权）
protected void	onStomp(StompSessionImpl session, Frame frame) Stomp 帧接收
protected void	stompToListener(StompSessionImpl session, Frame frame) Stomp 帧转给监听器

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

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

从接口继承的方法 org.noear.solon.net.websocket.WebSocketListener

onPing, onPong

构造器详细资料

ToStompWebSocketListener

protected ToStompWebSocketListener(java.lang.String endpoint,
                                   StompBrokerMedia brokerMedia)

方法详细资料

getSubProtocols

public java.lang.String getSubProtocols(@Nullable
                                        java.util.Collection<java.lang.String> requestProtocols)

指定者:

getSubProtocols 在接口中 SubProtocolCapable

onOpen

public void onOpen(WebSocket socket)

从接口复制的说明: WebSocketListener

连接打开时（可以做个签权）

指定者:

onOpen 在接口中 WebSocketListener

onMessage

public void onMessage(WebSocket socket,
                      java.nio.ByteBuffer binary)
               throws java.io.IOException

从接口复制的说明: WebSocketListener

收到消息时

指定者:

onMessage 在接口中 WebSocketListener

抛出:

java.io.IOException

onMessage

public void onMessage(WebSocket socket,
                      java.lang.String text)
               throws java.io.IOException

从接口复制的说明: WebSocketListener

收到消息时

指定者:

onMessage 在接口中 WebSocketListener

抛出:

java.io.IOException

onClose

public void onClose(WebSocket socket)

从接口复制的说明: WebSocketListener

连接关闭时

指定者:

onClose 在接口中 WebSocketListener

onError

public void onError(WebSocket socket,
                    java.lang.Throwable error)

从接口复制的说明: WebSocketListener

出错时

指定者:

onError 在接口中 WebSocketListener

onStomp

protected void onStomp(StompSessionImpl session,
                       Frame frame)

Stomp 帧接收

stompToListener

protected void stompToListener(StompSessionImpl session,
                               Frame frame)

Stomp 帧转给监听器