Main.java

// usage: when generating the binding code, do cmake -DCCAPI_ENABLE_LOG_TRACE=ON ..., see https://github.com/crypto-chassis/ccapi#non-c
import com.cryptochassis.ccapi.Logger;
import com.cryptochassis.ccapi.Session;
import com.cryptochassis.ccapi.SessionConfigs;
import com.cryptochassis.ccapi.SessionOptions;
import com.cryptochassis.ccapi.Subscription;
import java.util.concurrent.locks.ReentrantLock;

public class Main {
 static class MyLogger extends Logger {
 @Override
 public void logMessage(String severity, String threadId, String timeISO, String fileName, String lineNumber, String message) {
 this.lock.lock();
 try {
 System.out.println(String.format("%s: [%s] {%s:%s} %s%s%s", threadId, timeISO, fileName, lineNumber, severity, " ".repeat(8), message));
 } finally {
 this.lock.unlock();
 }
 }
 ReentrantLock lock = new ReentrantLock();
 }
 public static void main(String[] args) {
 System.loadLibrary("ccapi_binding_java");
 var myLogger = new MyLogger();
 Logger.setLogger(myLogger);
 var option = new SessionOptions();
 var config = new SessionConfigs();
 var session = new Session(option, config);
 var subscription = new Subscription("okx", "BTC-USDT", "MARKET_DEPTH");
 session.subscribe(subscription);
 try {
 Thread.sleep(10000);
 } catch (InterruptedException e) {
 }
 session.stop();
 System.out.println("Bye");
 }
}