Skip to content

Commit f4d80ea

Browse files
committed
Some detailed polish
1 parent bc3eb86 commit f4d80ea

File tree

6 files changed

+7
-18
lines changed

6 files changed

+7
-18
lines changed

openmessaging-api/src/main/java/io/openmessaging/Message.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -274,9 +274,9 @@ interface BuiltinKeys {
274274
String TraceId = "TraceId";
275275

276276
/**
277-
* The {@code RetryNumbers} header field contains a number, which represents the number of message delivery.
277+
* The {@code RetryNumber} header field contains a number, which represents the number of message delivery.
278278
*/
279-
String RetryNumbers = "RetryNumbers";
279+
String RetryNumber = "RetryNumber";
280280

281281
/**
282282
* The {@code RetryReason} header field contains the text description of the reason that causes

openmessaging-api/src/main/java/io/openmessaging/OMSBuiltinKeys.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -36,15 +36,4 @@ public interface OMSBuiltinKeys {
3636
String END_POSITION = "oms.end.position";
3737
String BEGIN_TIMESTAMP = "oms.begin.timestamp";
3838
String END_TIMESTAMP = "oms.end.timestamp";
39-
40-
/**
41-
* There are three order policies:
42-
*
43-
* <ul>
44-
* <li>ANY_ORDER</li>
45-
* <li>FIFO_ORDER</li>
46-
* <li>LIFO_ORDER</li>
47-
* </ul>
48-
*/
49-
String ORDER_POLICY = "order.policy";
5039
}

openmessaging-api/src/main/java/io/openmessaging/consumer/PullConsumer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import io.openmessaging.exception.OMSRuntimeException;
2626

2727
/**
28-
* A {@code PullConsumer} object can pull messages from the specified queue,
28+
* A {@code PullConsumer} pulls messages from the specified queue,
2929
* and supports submit the consume result by acknowledgement.
3030
*
3131
* @version OMS 1.0
@@ -75,7 +75,7 @@ public interface PullConsumer extends ServiceLifecycle {
7575
Message pull(KeyValue properties);
7676

7777
/**
78-
* Acknowledges the specified and consumed message, with unique message id.
78+
* Acknowledges the specified and consumed message with unique message id.
7979
* <p>
8080
* Messages that have been received but not acknowledged may be redelivered.
8181
*

openmessaging-api/src/main/java/io/openmessaging/consumer/PushConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
import io.openmessaging.interceptor.PushConsumerInterceptor;
2727

2828
/**
29-
* A {@code PushConsumer} object to receive messages from multiple queues, these messages are pushed from
29+
* A {@code PushConsumer} receives messages from multiple queues, these messages are pushed from
3030
* MOM server to {@code PushConsumer} client.
3131
*
3232
* @version OMS 1.0

openmessaging-api/src/main/java/io/openmessaging/producer/BatchMessageSender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import io.openmessaging.Message;
55

66
/**
7-
* A message sender created through {@link Producer#createSequenceBatchMessageSender()}, to send
7+
* A message sender created through {@link Producer#createBatchMessageSender()}, to send
88
* messages in batch way, and commit or roll back at the appropriate time.
99
*
1010
* @version OMS 1.0

openmessaging-api/src/main/java/io/openmessaging/producer/Producer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
163163
*
164164
* @return a {@code BatchMessageSender} instance
165165
*/
166-
BatchMessageSender createSequenceBatchMessageSender();
166+
BatchMessageSender createBatchMessageSender();
167167

168168
/**
169169
* Adds a {@code ProducerInterceptor} to intercept send operations of producer.

0 commit comments

Comments
 (0)