Skip to content

Commit 4715b42

Browse files
caozj1011caozj1011
committed
fix CI
1 parent b13974c commit 4715b42

File tree

1 file changed

+14
-14
lines changed

1 file changed

+14
-14
lines changed

‎src/zh/UserGuide/latest/API/Programming-Java-Native-API.md‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -734,16 +734,16 @@ occupied：用于记录正在被占用的连接
734734
|-------------------------------------|--------------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
735735
| `open()` | 打开消费者连接，启动消息消费。如果 `autoCommit` 启用，会启动自动提交工作器。 | 无 |
736736
| `close()` | 关闭消费者连接。如果 `autoCommit` 启用，会在关闭前提交所有未提交的消息。 | 无 |
737-
| `poll(final Duration timeout)` | 拉取消息，指定超时时间。 | `timeout` (Duration): 拉取的超时时间。 |
738-
| `poll(final long timeoutMs)` | 拉取消息，指定超时时间（毫秒）。 | `timeoutMs` (long): 超时时间，单位为毫秒。 |
739-
| `poll(final Set<String> topicNames, final Duration timeout)` | 拉取指定主题的消息，指定超时时间。 | `topicNames` (Set<String>): 要拉取的主题集合。<br>`timeout` (Duration): 超时时间。 |
740-
| `poll(final Set<String> topicNames, final long timeoutMs)` | 拉取指定主题的消息，指定超时时间（毫秒）。 | `topicNames` (Set<String>): 要拉取的主题集合。<br>`timeoutMs` (long): 超时时间，单位为毫秒。 |
741-
| `commitSync(final SubscriptionMessage message)` | 同步提交单条消息。 | `message` (SubscriptionMessage): 需要提交的消息对象。 |
742-
| `commitSync(final Iterable<SubscriptionMessage> messages)` | 同步提交多条消息。 | `messages` (Iterable<SubscriptionMessage>): 需要提交的消息集合。 |
743-
| `commitAsync(final SubscriptionMessage message)` | 异步提交单条消息。 | `message` (SubscriptionMessage): 需要提交的消息对象。 |
744-
| `commitAsync(final Iterable<SubscriptionMessage> messages)` | 异步提交多条消息。 | `messages` (Iterable<SubscriptionMessage>): 需要提交的消息集合。 |
745-
| `commitAsync(final SubscriptionMessage message, final AsyncCommitCallback callback)` | 异步提交单条消息并指定回调函数。 | `message` (SubscriptionMessage): 需要提交的消息对象。<br>`callback` (AsyncCommitCallback): 异步提交完成后的回调函数。 |
746-
| `commitAsync(final Iterable<SubscriptionMessage> messages, final AsyncCommitCallback callback)` | 异步提交多条消息并指定回调函数。 | `messages` (Iterable<SubscriptionMessage>): 需要提交的消息集合。<br>`callback` (AsyncCommitCallback): 异步提交完成后的回调函数。 |
737+
| `poll(final Duration timeout)` | 拉取消息，指定超时时间。 | `timeout` : 拉取的超时时间。 |
738+
| `poll(final long timeoutMs)` | 拉取消息，指定超时时间（毫秒）。 | `timeoutMs` : 超时时间，单位为毫秒。 |
739+
| `poll(final Set<String> topicNames, final Duration timeout)` | 拉取指定主题的消息，指定超时时间。 | `topicNames` : 要拉取的主题集合。`timeout`: 超时时间。 |
740+
| `poll(final Set<String> topicNames, final long timeoutMs)` | 拉取指定主题的消息，指定超时时间（毫秒）。 | `topicNames` : 要拉取的主题集合。`timeoutMs`: 超时时间，单位为毫秒。 |
741+
| `commitSync(final SubscriptionMessage message)` | 同步提交单条消息。 | `message` : 需要提交的消息对象。 |
742+
| `commitSync(final Iterable<SubscriptionMessage> messages)` | 同步提交多条消息。 | `messages` : 需要提交的消息集合。 |
743+
| `commitAsync(final SubscriptionMessage message)` | 异步提交单条消息。 | `message` : 需要提交的消息对象。 |
744+
| `commitAsync(final Iterable<SubscriptionMessage> messages)` | 异步提交多条消息。 | `messages` : 需要提交的消息集合。 |
745+
| `commitAsync(final SubscriptionMessage message, final AsyncCommitCallback callback)` | 异步提交单条消息并指定回调函数。 | `message` : 需要提交的消息对象。`callback` : 异步提交完成后的回调函数。 |
746+
| `commitAsync(final Iterable<SubscriptionMessage> messages, final AsyncCommitCallback callback)` | 异步提交多条消息并指定回调函数。 | `messages` : 需要提交的消息集合。`callback` : 异步提交完成后的回调函数。 |
747747

748748
##### SubscriptionPushConsumer
749749

@@ -755,8 +755,8 @@ occupied：用于记录正在被占用的连接
755755
| `coreReportMessage()` | 获取消费者核心配置的键值对表示形式。 | 无 |
756756
| `allReportMessage()` | 获取消费者所有配置的键值对表示形式。 | 无 |
757757
| `buildPushConsumer()` | 通过 `Builder` 构建 `SubscriptionPushConsumer` 实例。 | 无 |
758-
| `ackStrategy(final AckStrategy ackStrategy)` | 配置消费者的消息确认策略。 | `ackStrategy` (AckStrategy): 指定的消息确认策略。 |
759-
| `consumeListener(final ConsumeListener consumeListener)` | 配置消费者的消息消费逻辑。 | `consumeListener` (ConsumeListener): 消费者接收消息时的处理逻辑。 |
760-
| `autoPollIntervalMs(final long autoPollIntervalMs)` | 配置自动轮询的时间间隔。 | `autoPollIntervalMs` (long): 自动轮询的间隔时间，单位为毫秒。 |
761-
| `autoPollTimeoutMs(final long autoPollTimeoutMs)` | 配置自动轮询的超时时间。 | `autoPollTimeoutMs` (long): 自动轮询的超时时间，单位为毫秒。 |
758+
| `ackStrategy(final AckStrategy ackStrategy)` | 配置消费者的消息确认策略。 | `ackStrategy`: 指定的消息确认策略。 |
759+
| `consumeListener(final ConsumeListener consumeListener)` | 配置消费者的消息消费逻辑。 | `consumeListener`: 消费者接收消息时的处理逻辑。 |
760+
| `autoPollIntervalMs(final long autoPollIntervalMs)` | 配置自动轮询的时间间隔。 | `autoPollIntervalMs` : 自动轮询的间隔时间，单位为毫秒。 |
761+
| `autoPollTimeoutMs(final long autoPollTimeoutMs)` | 配置自动轮询的超时时间。 | `autoPollTimeoutMs`: 自动轮询的超时时间，单位为毫秒。 |
762762

0 commit comments

Comments
 (0)