Other Subscription Events

Connection Callbacks

Description

Handles events raised when the persistent TCP/TLS push connection opens, closes, or is replaced by another connection.

Callback interface

void connectionClosed() // Connection has been closed
void connectionAck() // Connection acknowledged without heartbeat negotiation values
void connectionAck(int serverSendInterval, int serverReceiveInterval) // Connection acknowledged with server heartbeat intervals
void connectionKickout(int errorCode, String errorMsg) // Connection kicked out by another connection
void hearBeat(String heartBeatContent) // Connection heartbeat callback
void serverHeartBeatTimeOut(String channelId) // Server heartbeat timeout

Example

The following excerpt shows only the connection-related methods from a complete ApiComposeCallback implementation:

@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);
}

Exception Callbacks

Description

Handles errors raised by a streaming subscription.

Callback interface

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

Example

The following excerpt shows only the error-related methods from a complete ApiComposeCallback implementation:

@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);
}