com.taosdata.jdbc.ws.tmq.entity

## 类 TMQRequestFactory

- java.lang.Object
- - com.taosdata.jdbc.ws.tmq.entity.TMQRequestFactory

    public class TMQRequestFactory
    extends Object

generate id for request

### 构造器概要

构造器
构造器和说明
`TMQRequestFactory()`

### 方法概要

所有方法 实例方法 具体方法
`Request` `generateAssignment(String topic)`
`Request` `generateCommit(long messageId)`
`Request` `generateFetch(long messageId)`
`Request` `generateFetchBlock(long fetchRequestId, long messageId)`
`Request` `generatePoll(long blockingTime)`
`Request` `generateSeek(String topic, int vgId, long offset)`
`Request` `generateSubscribe(String user, String password, String db, String groupId, String clientId, String offsetRest, String[] topics, String enableAutoCommit, String autoCommitIntervalMs, String snapshotEnable, String withTableName)`
`Request` `generateUnsubscribe()`
`long` `getId(String action)`

### 从类继承的方法 java.lang.Object

`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

### 构造器详细资料

#### TMQRequestFactory

    public TMQRequestFactory()

### 方法详细资料

#### getId

    public long getId(String action)

#### generateSubscribe

    public Request generateSubscribe(String user,
                                     String password,
                                     String db,
                                     String groupId,
                                     String clientId,
                                     String offsetRest,
                                     String[] topics,
                                     String enableAutoCommit,
                                     String autoCommitIntervalMs,
                                     String snapshotEnable,
                                     String withTableName)

#### generatePoll

    public Request generatePoll(long blockingTime)

#### generateFetch

    public Request generateFetch(long messageId)

#### generateFetchBlock

    public Request generateFetchBlock(long fetchRequestId,
                                      long messageId)

#### generateCommit

    public Request generateCommit(long messageId)

#### generateSeek

    public Request generateSeek(String topic,
                                int vgId,
                                long offset)

#### generateAssignment

    public Request generateAssignment(String topic)

#### generateUnsubscribe

    public Request generateUnsubscribe()