| 程序包 | 说明 |
|---|---|
| com.taosdata.jdbc.ws | |
| com.taosdata.jdbc.ws.entity | |
| com.taosdata.jdbc.ws.tmq.entity |
| 限定符和类型 | 方法和说明 |
|---|---|
Response |
Transport.send(Request request) |
void |
Transport.sendWithoutRep(Request request) |
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
RequestFactory.generateFetch(long id) |
Request |
RequestFactory.generateFetchBlock(long id) |
Request |
RequestFactory.generateFetchJson(long id) |
Request |
RequestFactory.generateQuery(String sql) |
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
TMQRequestFactory.generateCommit(long messageId) |
Request |
TMQRequestFactory.generateFetch(long messageId) |
Request |
TMQRequestFactory.generateFetchBlock(long fetchRequestId,
long messageId) |
Request |
TMQRequestFactory.generatePoll(long blockingTime) |
Request |
TMQRequestFactory.generateSubscribe(String user,
String password,
String db,
String groupId,
String clientId,
String offsetRest,
String[] topics) |
Copyright © 2023. All rights reserved.