Я выполняю тестирование потоковых данных в кластере dolphindb, в узле данных есть потоковая таблица, я подписал потоковые данные на java api, но данные не получены. я использую ThreadedClient для подписки на streamTable и без исключений, кто-нибудь может помочь?
мой java код
public static void main(String args[]) throws SocketException {
ThreadedClient client = new ThreadedClient(8849); //the subPort set to 8849
try {
client.subscribe("192.168.1.42", 8848, "trades", "action1", new SampleMessageHandler());
} catch (IOException e) {
e.printStackTrace();
}
}
public class SampleMessageHandler implements MessageHandler {
@Override
public void doEvent(IMessage msg) {
System.out.println(msg.getValue(0));
}
}