Other Subscription Events

Connection Callbacks

Description

Callbacks for when long connections are established or disconnected

Callback Interface

void connectionClosed() // Connection has been closed
void connectAck() // Connection successful
void connectionKickout(int errorCode, String errorMsg) // Connection kicked out by another connection
void hearBeat(String s) // Connection heartbeat callback

Example

package com.tigerbrokers.stock.openapi.demo;

import com.alibaba.fastjson.JSONObject;
import com.tigerbrokers.stock.openapi.client.socket.ApiComposeCallback;


public class DefaultApiComposeCallback implements 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("connect ack.");
  }

  @Override
  public void hearBeat(String s) {

  }

  @Override
  public void serverHeartBeatTimeOut(String s) {

  }
}

Exception Callbacks

Description

Callbacks for subscription exceptions

Callback Interface

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

Example

package com.tigerbrokers.stock.openapi.demo;

import com.alibaba.fastjson.JSONObject;
import com.tigerbrokers.stock.openapi.client.socket.ApiComposeCallback;


public class DefaultApiComposeCallback implements 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);
  }
}