其他订阅事件

连接回调

说明

处理 TCP/TLS 推送长连接建立、关闭或被其他连接替换时触发的事件。

回调接口

void connectionClosed() // 连接已关闭
void connectionAck() // 连接成功（无心跳协商参数）
void connectionAck(int serverSendInterval, int serverReceiveInterval) // 连接成功及服务端心跳间隔
void connectionKickout(int errorCode, String errorMsg) // 连接被另一个连接踢掉
void hearBeat(String heartBeatContent) // 连接心跳回调
void serverHeartBeatTimeOut(String channelId) // 服务端心跳超时

示例

以下代码仅展示完整 ApiComposeCallback 实现中的连接相关方法：

@Override
public void connectionClosed() {
  System.out.println("connection closed.");
}

@Override
public void connectionKickout(int errorCode, String errorMsg) {
  System.out.println(errorMsg + " and the connection is closed.");
}

@Override
public void connectionAck() {
  System.out.println("connection acknowledged.");
}

@Override
public void connectionAck(int serverSendInterval, int serverReceiveInterval) {
  System.out.println("connection acknowledged. serverSendInterval=" + serverSendInterval
      + ", serverReceiveInterval=" + serverReceiveInterval);
}

@Override
public void hearBeat(String heartBeatContent) {
  System.out.println("heartbeat: " + heartBeatContent);
}

@Override
public void serverHeartBeatTimeOut(String channelId) {
  System.out.println("server heartbeat timed out: " + channelId);
}

异常回调

说明

订阅异常时的回调

回调接口

void error(String errorMsg)
void error(int id, int errorCode, String errorMsg)

示例

以下代码仅展示完整 ApiComposeCallback 实现中的异常相关方法：

@Override
public void error(String errorMsg) {
  System.out.println("receive error:" + errorMsg);
}

@Override
public void error(int id, int errorCode, String errorMsg) {
  System.out.println("receive error id:" + id + ",errorCode:" + errorCode + ",errorMsg:" + errorMsg);
}