This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from e3352d4 Add Github badge
add 9f8dd3f Add readme for java client
add 70a66a8 Java: fix checkstyle
No new revisions were added by this update.
Summary of changes:
java/README.md | 47 +++
.../rocketmq/client/apis/ClientConfiguration.java | 11 +-
.../client/apis/ClientConfigurationBuilder.java | 4 +-
.../rocketmq/client/apis/SessionCredentials.java | 4 +-
.../client/apis/consumer/FilterExpression.java | 7 +-
.../client/apis/consumer/MessageListener.java | 3 +-
.../client/apis/consumer/SimpleConsumer.java | 25 +-
.../apis/consumer/SimpleConsumerBuilder.java | 3 +-
java/{client-apis => client-shade}/pom.xml | 8 +-
java/{client-java => client}/pom.xml | 2 +-
.../client/java/ClientServiceProviderImpl.java | 0
.../org/apache/rocketmq/client/java/UserAgent.java | 5 +-
.../java/exception/ResourceNotFoundException.java | 0
.../client/java/hook/MessageHookPoints.java | 0
.../client/java/hook/MessageHookPointsStatus.java | 0
.../client/java/hook/MessageInterceptor.java | 0
.../apache/rocketmq/client/java/impl/Client.java | 0
.../rocketmq/client/java/impl/ClientImpl.java | 96 ++---
.../rocketmq/client/java/impl/ClientManager.java | 0
.../client/java/impl/ClientManagerImpl.java | 4 +-
.../client/java/impl/ClientManagerRegistry.java | 0
.../rocketmq/client/java/impl/ClientSettings.java | 0
.../rocketmq/client/java/impl/ClientType.java | 0
.../client/java/impl/TelemetrySession.java | 44 ++-
.../client/java/impl/consumer/Assignment.java | 0
.../client/java/impl/consumer/Assignments.java | 0
.../client/java/impl/consumer/ConsumeService.java | 4 +-
.../client/java/impl/consumer/ConsumeTask.java | 7 +-
.../client/java/impl/consumer/ConsumerImpl.java | 36 +-
.../java/impl/consumer/FifoConsumeService.java | 7 +-
.../client/java/impl/consumer/ProcessQueue.java | 0
.../java/impl/consumer/ProcessQueueImpl.java | 105 ++++--
.../impl/consumer/PushConsumerBuilderImpl.java | 9 +-
.../java/impl/consumer/PushConsumerImpl.java | 55 +--
.../java/impl/consumer/PushConsumerSettings.java | 19 +-
.../java/impl/consumer/ReceiveMessageResult.java | 0
.../impl/consumer/SimpleConsumerBuilderImpl.java | 13 +-
.../java/impl/consumer/SimpleConsumerImpl.java | 50 ++-
.../java/impl/consumer/SimpleConsumerSettings.java | 16 +-
.../java/impl/consumer/StandardConsumeService.java | 7 +-
.../consumer/SubscriptionTopicRouteDataResult.java | 3 +-
.../java/impl/producer/ProducerBuilderImpl.java | 9 +-
.../client/java/impl/producer/ProducerImpl.java | 99 ++++--
.../java/impl/producer/ProducerSettings.java | 14 +-
.../producer/PublishingTopicRouteDataResult.java | 0
.../client/java/impl/producer/SendReceiptImpl.java | 4 +-
.../client/java/impl/producer/TransactionImpl.java | 24 +-
.../client/java/logging/CustomConsoleAppender.java | 3 +-
.../client/java/logging/ProcessIdConverter.java | 0
.../client/java/message/MessageBuilderImpl.java | 6 +-
.../client/java/message/MessageCommon.java | 6 +-
.../client/java/message/MessageIdCodec.java | 5 +-
.../client/java/message/MessageIdImpl.java | 0
.../rocketmq/client/java/message/MessageImpl.java | 14 +-
.../rocketmq/client/java/message/MessageType.java | 0
.../client/java/message/MessageViewImpl.java | 31 +-
.../client/java/message/PublishingMessageImpl.java | 6 +-
.../client/java/message/protocol/Encoding.java | 0
.../client/java/message/protocol/Resource.java | 0
.../client/java/metrics/MessageCacheObserver.java | 0
.../rocketmq/client/java/metrics/MessageMeter.java | 55 ++-
.../rocketmq/client/java/metrics/Metric.java | 0
.../java/metrics/MetricMessageInterceptor.java | 10 +-
.../rocketmq/client/java/metrics/MetricName.java | 0
.../client/java/metrics/RocketmqAttributes.java | 9 +-
.../rocketmq/client/java/misc/Dispatcher.java | 4 +-
.../client/java/misc/ExecutorServices.java | 0
.../rocketmq/client/java/misc/LinkedElement.java | 0
.../rocketmq/client/java/misc/LinkedIterator.java | 0
.../rocketmq/client/java/misc/MetadataUtils.java | 0
.../client/java/misc/RequestIdGenerator.java | 0
.../client/java/misc/ThreadFactoryImpl.java | 0
.../rocketmq/client/java/misc/Utilities.java | 6 +-
.../java/retry/CustomizedBackoffRetryPolicy.java | 10 +-
.../java/retry/ExponentialBackoffRetryPolicy.java | 12 +-
.../rocketmq/client/java/retry/RetryPolicy.java | 0
.../apache/rocketmq/client/java/route/Address.java | 0
.../rocketmq/client/java/route/AddressScheme.java | 0
.../apache/rocketmq/client/java/route/Broker.java | 3 +-
.../rocketmq/client/java/route/Endpoints.java | 7 +-
.../client/java/route/MessageQueueImpl.java | 0
.../rocketmq/client/java/route/Permission.java | 0
.../rocketmq/client/java/route/TopicRouteData.java | 3 +-
.../client/java/route/TopicRouteDataResult.java | 4 +-
.../rocketmq/client/java/rpc/AuthInterceptor.java | 4 +-
.../client/java/rpc/IpNameResolverFactory.java | 0
.../client/java/rpc/LoggingInterceptor.java | 16 +-
.../apache/rocketmq/client/java/rpc/RpcClient.java | 0
.../rocketmq/client/java/rpc/RpcClientImpl.java | 2 +-
.../apache/rocketmq/client/java/rpc/Signature.java | 0
.../apache/rocketmq/client/java/rpc/TLSHelper.java | 0
.../rocketmq.metadata.properties | 0
...ache.rocketmq.client.apis.ClientServiceProvider | 0
.../src/main/resources/logback.xml | 0
.../client/java/ClientServiceProviderImplTest.java | 10 +-
.../client/java/impl/ClientManagerImplTest.java | 0
.../java/impl/consumer/ProcessQueueImplTest.java | 51 +--
.../impl/consumer/PushConsumerBuilderImplTest.java | 3 +-
.../java/impl/consumer/PushConsumerImplTest.java | 60 ++--
.../impl/consumer/SimpleConsumerBuilderTest.java | 3 +-
.../java/impl/consumer/SimpleConsumerImplTest.java | 76 ++--
.../impl/consumer/StandardConsumeServiceTest.java | 15 +-
.../impl/producer/ProducerBuilderImplTest.java | 5 +-
.../java/impl/producer/ProducerImplTest.java | 93 +++--
.../java/impl/producer/TransactionImplTest.java | 32 +-
.../client/java/message/MessageIdCodecTest.java | 5 +-
.../client/java/message/MessageImplTest.java | 22 +-
.../retry/CustomizedBackoffRetryPolicyTest.java | 6 +-
.../rocketmq/client/java/route/EndpointsTest.java | 6 +-
.../apache/rocketmq/client/java/tool/TestBase.java | 36 +-
.../org.mockito.plugins.MockMaker | 0
java/pom.xml | 35 +-
java/style/checkstyle.xml | 385 +++++++++++++++++++++
java/style/intellij-codestyle.xml | 67 ++++
java/style/spotbugs-suppressions.xml | 12 +
115 files changed, 1346 insertions(+), 536 deletions(-)
create mode 100644 java/README.md
copy java/{client-apis => client-shade}/pom.xml (71%)
rename java/{client-java => client}/pom.xml (97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/ClientServiceProviderImpl.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/UserAgent.java (94%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/exception/ResourceNotFoundException.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/hook/MessageHookPoints.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/hook/MessageHookPointsStatus.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/hook/MessageInterceptor.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/Client.java (100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java (94%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/ClientManager.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerRegistry.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/ClientSettings.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/ClientType.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/TelemetrySession.java
(88%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/Assignment.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/Assignments.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeService.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeTask.java
(97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java
(91%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/FifoConsumeService.java
(97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueue.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java
(87%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerBuilderImpl.java
(97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java
(93%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerSettings.java
(89%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ReceiveMessageResult.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerBuilderImpl.java
(94%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerImpl.java
(89%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerSettings.java
(89%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/StandardConsumeService.java
(99%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SubscriptionTopicRouteDataResult.java
(97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerBuilderImpl.java
(95%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
(87%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerSettings.java
(89%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/producer/PublishingTopicRouteDataResult.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/producer/SendReceiptImpl.java
(94%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/impl/producer/TransactionImpl.java
(89%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/logging/CustomConsoleAppender.java
(91%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/logging/ProcessIdConverter.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageCommon.java
(95%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageIdCodec.java
(99%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageIdImpl.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageImpl.java
(98%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageType.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java
(93%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/PublishingMessageImpl.java
(97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/protocol/Encoding.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/message/protocol/Resource.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/metrics/MessageCacheObserver.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/metrics/MessageMeter.java
(88%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/metrics/Metric.java (100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/metrics/MetricMessageInterceptor.java
(98%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/metrics/MetricName.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/metrics/RocketmqAttributes.java
(96%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/Dispatcher.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/ExecutorServices.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/LinkedElement.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/LinkedIterator.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/MetadataUtils.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/RequestIdGenerator.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/ThreadFactoryImpl.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java (98%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/retry/CustomizedBackoffRetryPolicy.java
(95%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/retry/ExponentialBackoffRetryPolicy.java
(96%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/retry/RetryPolicy.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/Address.java (100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/AddressScheme.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/Broker.java (96%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/Endpoints.java (98%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/MessageQueueImpl.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/Permission.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/TopicRouteData.java
(97%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/route/TopicRouteDataResult.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/AuthInterceptor.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/IpNameResolverFactory.java
(100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/LoggingInterceptor.java
(86%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClient.java (100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java
(99%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java (100%)
rename java/{client-java =>
client}/src/main/java/org/apache/rocketmq/client/java/rpc/TLSHelper.java (100%)
rename java/{client-java =>
client}/src/main/resources-filtered/rocketmq.metadata.properties (100%)
rename java/{client-java =>
client}/src/main/resources/META-INF/services/org.apache.rocketmq.client.apis.ClientServiceProvider
(100%)
rename java/{client-java => client}/src/main/resources/logback.xml (100%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/ClientServiceProviderImplTest.java
(86%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/ClientManagerImplTest.java
(100%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImplTest.java
(90%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerBuilderImplTest.java
(96%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImplTest.java
(80%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerBuilderTest.java
(94%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerImplTest.java
(84%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/consumer/StandardConsumeServiceTest.java
(96%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/producer/ProducerBuilderImplTest.java
(97%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/producer/ProducerImplTest.java
(82%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/impl/producer/TransactionImplTest.java
(90%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/message/MessageIdCodecTest.java
(99%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/message/MessageImplTest.java
(96%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/retry/CustomizedBackoffRetryPolicyTest.java
(99%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/route/EndpointsTest.java
(96%)
rename java/{client-java =>
client}/src/test/java/org/apache/rocketmq/client/java/tool/TestBase.java (94%)
rename java/{client-java =>
client}/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker
(100%)
create mode 100644 java/style/checkstyle.xml
create mode 100644 java/style/intellij-codestyle.xml
create mode 100644 java/style/spotbugs-suppressions.xml
