Other Events

Connection Callbacks

Description

Callbacks when the long connection is established, or lost.

Callbacks

void connectionClosed() // Connection closed
void connectAck() // connected
void connectionKickout(int errorCode, String errorMsg) // connection is kicked out by another connection
void hearBeat(String s) // connection heartbeat

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) {

  }
}

Error

Description

Callback when an error occurs

Callbacks

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