[rocketmq] branch 5.0.0-beta updated (0b7291b -> 8fc952d)

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a change to branch 5.0.0-beta
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from 0b7291b  [ISSUE #3503] bugfix: the consumeOffset will be set as 0 when getMessage returns null (#3504)
     add 8fc952d  Add new APIs for producer (#3987)

No new revisions were added by this update.

Summary of changes:
 {openmessaging => apis}/pom.xml                    |  19 ++--
 .../apache/rocketmq/apis/ClientConfiguration.java  |  61 +++++++++++
 .../rocketmq/apis/ClientConfigurationBuilder.java  |  72 ++++++++++++
 .../rocketmq/apis/ClientServiceProvider.java       |  52 +++++++++
 .../org/apache/rocketmq/apis/MessageQueue.java     |  11 +-
 .../apache/rocketmq/apis/SessionCredentials.java   |  58 ++++++++++
 .../rocketmq/apis/SessionCredentialsProvider.java  |  13 ++-
 .../apis/StaticSessionCredentialsProvider.java     |  25 ++---
 .../apis/exception/AuthenticationException.java    |  31 ++----
 .../apis/exception/AuthorisationException.java     |  35 +++---
 .../rocketmq/apis/exception/ClientException.java   |  72 ++++++++++++
 .../apache/rocketmq/apis/exception/ErrorCode.java  |  84 ++++++++++++++
 .../apis/exception/FlowControlException.java       |  11 +-
 .../rocketmq/apis/exception/NetworkException.java  |  14 +--
 .../exception/RemoteIllegalArgumentException.java  |  12 +-
 .../apis/exception/ResourceNotFoundException.java  |  11 +-
 .../apis/exception/ResourceNotMatchException.java  |  10 +-
 .../rocketmq/apis/exception/TimeoutException.java  |  14 +--
 .../org/apache/rocketmq/apis/message/Message.java  |  77 +++++++++++++
 .../rocketmq/apis/message/MessageBuilder.java      |  91 ++++++++++++++++
 .../apache/rocketmq/apis/message/MessageId.java    |  33 +++---
 .../rocketmq/apis/message/MessageIdVersion.java    |  13 ++-
 .../apache/rocketmq/apis/message/MessageView.java  | 121 +++++++++++++++++++++
 .../apache/rocketmq/apis/producer/Producer.java    | 100 +++++++++++++++++
 .../rocketmq/apis/producer/ProducerBuilder.java    |  82 ++++++++++++++
 .../apache/rocketmq/apis/producer/SendReceipt.java |  15 ++-
 .../apache/rocketmq/apis/producer/Transaction.java |  47 ++++++++
 .../rocketmq/apis/producer/TransactionChecker.java |  41 +++++++
 .../apis/producer/TransactionResolution.java       |  22 ++--
 .../apis/retry/BackOffRetryPolicyBuilder.java      |  59 ++++++++++
 .../rocketmq/apis/retry/BackoffRetryPolicy.java    |  86 +++++++++++++++
 .../apache/rocketmq/apis/retry/RetryPolicy.java    |  23 ++--
 pom.xml                                            |   4 +
 33 files changed, 1243 insertions(+), 176 deletions(-)
 copy {openmessaging => apis}/pom.xml (66%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/ClientConfiguration.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/ClientConfigurationBuilder.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/ClientServiceProvider.java
 copy common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java => apis/src/main/java/org/apache/rocketmq/apis/MessageQueue.java (87%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/SessionCredentials.java
 copy common/src/main/java/org/apache/rocketmq/common/consistenthash/Node.java => apis/src/main/java/org/apache/rocketmq/apis/SessionCredentialsProvider.java (75%)
 copy common/src/main/java/org/apache/rocketmq/common/consistenthash/VirtualNode.java => apis/src/main/java/org/apache/rocketmq/apis/StaticSessionCredentialsProvider.java (58%)
 copy client/src/main/java/org/apache/rocketmq/client/trace/TraceTransferBean.java => apis/src/main/java/org/apache/rocketmq/apis/exception/AuthenticationException.java (59%)
 copy client/src/main/java/org/apache/rocketmq/client/trace/TraceTransferBean.java => apis/src/main/java/org/apache/rocketmq/apis/exception/AuthorisationException.java (52%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/exception/ClientException.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/exception/ErrorCode.java
 copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java => apis/src/main/java/org/apache/rocketmq/apis/exception/FlowControlException.java (75%)
 copy common/src/main/java/org/apache/rocketmq/common/filter/FilterContext.java => apis/src/main/java/org/apache/rocketmq/apis/exception/NetworkException.java (72%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingTooMuchRequestException.java => apis/src/main/java/org/apache/rocketmq/apis/exception/RemoteIllegalArgumentException.java (73%)
 copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java => apis/src/main/java/org/apache/rocketmq/apis/exception/ResourceNotFoundException.java (74%)
 copy common/src/main/java/org/apache/rocketmq/common/utils/CorrelationIdUtil.java => apis/src/main/java/org/apache/rocketmq/apis/exception/ResourceNotMatchException.java (79%)
 copy common/src/main/java/org/apache/rocketmq/common/filter/FilterContext.java => apis/src/main/java/org/apache/rocketmq/apis/exception/TimeoutException.java (72%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/message/Message.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/message/MessageBuilder.java
 copy common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java => apis/src/main/java/org/apache/rocketmq/apis/message/MessageId.java (62%)
 copy client/src/main/java/org/apache/rocketmq/client/consumer/AckStatus.java => apis/src/main/java/org/apache/rocketmq/apis/message/MessageIdVersion.java (81%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/message/MessageView.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/producer/Producer.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/producer/ProducerBuilder.java
 copy store/src/main/java/org/apache/rocketmq/store/queue/ReferredIterator.java => apis/src/main/java/org/apache/rocketmq/apis/producer/SendReceipt.java (75%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/producer/Transaction.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/producer/TransactionChecker.java
 copy client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java => apis/src/main/java/org/apache/rocketmq/apis/producer/TransactionResolution.java (67%)
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/retry/BackOffRetryPolicyBuilder.java
 create mode 100644 apis/src/main/java/org/apache/rocketmq/apis/retry/BackoffRetryPolicy.java
 copy filter/src/main/java/org/apache/rocketmq/filter/FilterSpi.java => apis/src/main/java/org/apache/rocketmq/apis/retry/RetryPolicy.java (65%)