org.noear.solon.net.stomp.broker.impl

类 BrokerMediaStompListener

java.lang.Object

org.noear.solon.net.stomp.broker.impl.BrokerMediaStompListener

所有已实现的接口:

StompListener

public class BrokerMediaStompListener
extends java.lang.Object
implements StompListener

Stomp 代理中介监听器（收集协议元数据）

从以下版本开始:

2.7, 3.0

构造器概要

构造器

构造器和说明
BrokerMediaStompListener(StompBrokerMedia brokerMedia)

方法概要

限定符和类型	方法和说明
void	onAck(StompSession session, Frame frame) 消息ACK
void	onClose(StompSession session) 连接关闭 当连接断开时触发
void	onConnect(StompSession session, Frame frame) 连接命令 需要响应
void	onDisconnect(StompSession session, Frame frame) 断开命令 需要响应
void	onError(StompSession socket, java.lang.Throwable error) 出错时
void	onFrame(StompSession session, Frame frame) 收到消息帧
void	onOpen(StompSession session) 可以放鉴权，参数可以通过Head或者地址栏 鉴权失败可以直接关闭, 如：socket.close();
void	onSend(StompSession session, Frame frame) 发送消息
void	onSubscribe(StompSession session, Frame frame) 订阅命令
void	onUnsubscribe(StompSession socket, Frame frame) 取消订阅命令
protected void	unSubscribeHandle(java.util.function.Function<Subscription,java.lang.Boolean> function) 删除订阅

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

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

构造器详细资料

BrokerMediaStompListener

public BrokerMediaStompListener(StompBrokerMedia brokerMedia)

方法详细资料

onOpen

public void onOpen(StompSession session)

可以放鉴权，参数可以通过Head或者地址栏 鉴权失败可以直接关闭, 如：socket.close();

指定者:

onOpen 在接口中 StompListener

参数:

session -

onClose

public void onClose(StompSession session)

连接关闭 当连接断开时触发

指定者:

onClose 在接口中 StompListener

onFrame

public void onFrame(StompSession session,
                    Frame frame)

从接口复制的说明: StompListener

收到消息帧

指定者:

onFrame 在接口中 StompListener

frame - 帧

onError

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

从接口复制的说明: StompListener

出错时

指定者:

onError 在接口中 StompListener

onConnect

public void onConnect(StompSession session,
                      Frame frame)

连接命令 需要响应

onDisconnect

public void onDisconnect(StompSession session,
                         Frame frame)

断开命令 需要响应

onSubscribe

public void onSubscribe(StompSession session,
                        Frame frame)

订阅命令

onUnsubscribe

public void onUnsubscribe(StompSession socket,
                          Frame frame)

取消订阅命令

onSend

public void onSend(StompSession session,
                   Frame frame)

发送消息

onAck

public void onAck(StompSession session,
                  Frame frame)

消息ACK

unSubscribeHandle

protected void unSubscribeHandle(java.util.function.Function<Subscription,java.lang.Boolean> function)

删除订阅

参数:

function -