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 f57efb8 [RIP-37] Add new APIs for consumer
new c6f9a57 Initial commit
new dec1416 Add readme
new 42c4b4c Add UT
new c912703 Polish code
new 347160e Check coverage before compile
new 6a61f88 Polish code
new ee166e7 Using semaphore to limit the submittal of sending message task
new 5dd15eb Make it compatiable with Java1.6
new c8ab417 Update ci script
new 8e2985f Polish code
new ad00031 Polish code
new 5c4f9dd Update nameserver address from topAddressing
new 7eee691 Fix typo
new 6dec2f0 Polish code
new c79d014 Expose more parameter in RPCClientImpl
new a8b789b Implement DefaultMQPushConsumerImpl
new 829f0d1 Provide a switch for consumer to decide if ack message
asynchronously
new 240c574 Polish code
new a0b3a75 Add UT
new 8d122c4 Implement ProcessQueue#isPopExpired
new 50899b2 Polish code
new ad3c9a9 Add more UT
new 15a7f96 Fix typo
new 9434171 Dev
new 3cfa5f3 Apply checkstyle
new 2a94c91 Update README
new 3d5e709 Support CI system
new b296260 Distinct version of customized gRPC and protocol buffer from
official one
new 2334eae Provide example for ONS
new 041b959 Using snapshot of grpc and protobuffer
new 17109a4 Update readme
new 936444e Compile the whole project using local environment
new c4e08fb Replace the IDL by the latest version
new b10da29 Unify grpc header by customized interceptor
new d1194c0 Implement Skeleton of ONS consumer
new 55e1b07 Cache IPv4 address and processId
new af8f8dc Implement ons push consumer
new 1b48c99 Update grpc protocol
new 0c24460 Polish code
new 077217b Add dependency for openTelemetry
new 808efac Provide method to serialize the trace context
new 4a13d52 Expose function to update addresses for name resolver
new 10c5b21 Bugfix: do not register global name resolver
new d6f8349 Seperate thread pool with each other in ClientInstance
new 4e27b93 Provide switch for client to enable tracing
new 9360ba0 Polish code
new 9ee51c1 Bugfix: correct target format
new 0526333 Polish code
new eed95cb Update to the latest IDL
new e7e7f6f Polish code
new 7554fe1 Support message tracing for asyn sending
new 8b0c484 Using sendCallbackExecutor instead of async rpc executor
new 012bfaf Do not register openTelemetrySdk globally
new 6f1ca6a Enable channelz
new 97ddc4a Fix issue of compatibility
new 62498fe Apply spotbugs's suggestion
new 9d36198 Set digest for message
new 500f5b5 Shade and relocate dependencies in ons-client
new 13691af Re-organize the file structure
new 88f17e3 Polish code
new bfbd373 Bugfix: remove message queue while expirede to pop messsage
new 62b858e Set max reconsumeTimes for DeadLetterPolicy
new b305fbc Polish code
new 07a9234 Add consumeModel for NackMessageRequest
new 142e2d4 Make it compile
new 5c561fe Bugfix: fix async-sending issues
new 7a63427 Shutdown receiveCallback executor
new a2f9ad0 WIP: implement message tracing
new 9c6b527 Polish code
new 9ee87e4 Bugfix: inject traceContext into system properties of message
new 95e4780 Polish code
new 429ba6c Polish code
new 4121713 Bugfix: only increment popTimes while status is FOUND
new 66fb53a WIP: implement transaction producer
new 491b81c Update to the latest IDL
new 2278f0a Mark thread index as static
new a13d744 Remove clientInstanceConfig
new b4b150f WIP: implement transation message
new a026486 Polish code
new 04bbe3d Bugfix: doHeartbeat thread exit in advance
new 3e4c5ce Polish code
new 062da76 Polish code
new c2c4a75 WIP: implement pull consumer
new 74f1176 Support timer message
new 807e711 Fix a series of issue
new ae527a0 Add dependency for guava
new b01ac78 Remove ons module
new f64a264 Provide example for timerMessage
new 95fea95 Provide example for pullConsumer
new f5f4fc4 Provide API for pullConsumer
new ba6deb8 Update to the latest IDL
new 1d15412 Remove clientInstanceManager
new a987caa Support multiple nameserver address
new aac52f1 WiP: support pull consumer
new 22cc372 Delete TopicPublishInfo
new 37cb33a Add logging module
new 19287c3 Update to the latest IDL
new 6c9b5e6 WiP: implement pull consumer
new d59c793 Remove load assignments scanner from clientInstance
new 42624d8 Remove consumerObserver and producerObserver
new 4e0fd65 Polish code for async producer
new cd59a74 Provide shaded logback
new e95a868 Shade slf4j
new 54ae086 Update to the latest IDL
new 8aea590 Polish code
new f6b5561 Bugfix: remove future in ClientBaseImpl#getRouteFor
new b9beba0 Provide AOP ability for message
new 40f1c9a Apply builder model for MessageInterceptorContext
new e8f25fe Polish code
new bdfcadf Update message compression threshold
new 75733ac Fix typo
new b02299f Remove admin module
new e742ee2 Polish code
new 59867f3 Using the same messageId for retry
new f99aa50 Polish code
new ba61610 Update to the latest IDL
new 6587185 Add brokerName to receiveMessageRequest
new 3687da7 Rename dynamic link library for shade
new 5a685fb Polish code
new 6b48131 Delete useless code
new d5ddd1e Apply trace interceptor for rpc client
new 1a16f73 Polish log
new b3dffd4 Bugfix: messageType was not set before sending
new ed733aa Polish code
new d2b7d28 Update rule of message id
new 5758a56 Bugfix: isolate endpoints while failed to send message
new 92d066a Polish code
new 7567e9c Bugfix: return futurn0 while updating topic route cache
new 054e952 Move consume thread pool to impl
new d437787 WiP: refactor consumerImpl
new cfa09a9 Polish code
new 29354b6 Bugfix: throttle message consumption rate in consumption task
new 21ea97e Revert "Bugfix: throttle message consumption rate in
consumption task"
new 71a6cec Polish code
new 0d525ac No need to ACK/NACK message for broadcasting
new 9aaf31c Update endpoints for transaction example
new 6a60dd0 Bugfix: call receiveMessage in receiveMessageLater
new 9e8f64e Polish code
new 4a89dbf Bugfix: use nanoTime instead of millseconds for receptionTime
and throttledTime
new f79be12 Update to the latest IDL
new b1fcae2 Update to the lastest IDL
new e3fdeb7 Add RpcClient#sendMessageToDeadLetterQueueC
new d9645c7 Dev
new 54e41c4 Refactor consumer
new e4f6f94 Update to the latest IDL
new 04aa8b3 Polish code
new 7f9bdf7 Bugfix: return the same future for ackFifo and forward
message to DLQ
new cded75a Polish code
new 13b591a Add unified thread name prefix
new bb98454 WiP: support broadcasting consumption
new 1aca354 Sync process queue anyway even the assignments unchanged.
new 83ca6cb Polish code
new bd79634 Remove async fifo message api
new cfb8629 Refactor consume service
new dc7640d Polish code for FIFO message
new 9a089b7 Fix typo
new 04553f8 Bugfix: erase fifomessage earlier when consumption status is
failure
new 305041b Polish code
new 47c36c0 Erase fifo message using consumption thread
new 0e30acc Update credentials to credentials provider
new 7a4bf01 Bugfix: fix spotbugs
new eedbf27 Fix UT
new b63216e Add more example
new ab3fe71 Add filterExpression#accept
new 084c4b3 Set different messageId if user send message to different
topic
new 854d2c2 Fix typo
new be2d48b Fix checkstyle
new 491dce1 Adapt it for ONS
new b6ba666 Support sts credentials provider
new 343c0c8 Polish code
new aa6e7f7 Allow consumer subscribe message using SQL92 filter
new 120dd1b Polish code
new 6663e4d Delete useless code
new dc115f2 Discard apache http client
new d525f53 Update to the latest IDL
new 8f142ce Bugfix: set tag and keys while sending message
new 85360d8 Polish code
new a38e4e5 Update to the lastest IDL
new 0731627 Update to the latest IDL
new 1dfbcbb Polish code
new c4267a9 Add ClientBaseImpl#beforeTopicRouteDataUpdate
new ee44cd9 Remove ci directory
new 88e81bb Add logback.xml
new ff4cc67 Polish code
new 15f28db Add ut
new 72b76ef Polish code
new bc02335 Polish code
new b914e5a Supply corrupted option for messageImpl
new ab0f0a6 Add ut
new e45d1bf Add comments
new 424bf3b Polish code
new d6f7c21 Set traceContext before message sending
new b396264 Bugfix: compare name server endpoints using equals instead of
'=='
new 35d1ae2 Add trace for end trasaction message
new e599c8e Bugfix: generate new list for remove pending message
new 5ccb0c4 Enable needRebalance for fifo message
new 0f87f2b Polish code
new 8b08df1 Parse arn from name server endpoints
new 50f2aca Judge scheduler is shutdown or not
new 4fd182a Bugfix: ensure DefaultMQPushConsumerImpl#getProcessQueue
never return null
new 6607b02 Bugfix: reverse MessageExt#corrupted
new 3c49641 Release offset record for broadcasting mode
new e3b566c Polish code
new 21811cf Update long polling timeout
new 56a3028 Polish code
new 69fc40f Link consumption trace span
new 0fac244 Bugfix: forget to set policy for QueryOffsetRequest
new 68a6f09 Add broker to PullMessageRequest
new 0239f5b Add broker to QueryOffsetRequest
new 8a74030 Re-calculate max await size for pull/receive request
according to the buffer size
new 8ebba01 Add host to span attribute
new 9ece267 Polish code
new debc0e6 Remove flatten-maven-plugin
new 012ed94 Remove lombok
new 12f2533 Shade slf4j in rocketmq-logback-shaded
new b34807a Fix source jar issue
new 63cb529 Remove powermock
new 21e1e29 Remove jna
new cc3e2d9 Using fixed window rolling policy for logback
new 813fbcd Handle the case that the message is corrupted
new 44e9608 Polish code
new 36b7db8 Add enforcer plugin
new cfa2270 Ban lombok
new ee2ab90 Polish code
new 38a01cd Fix typo
new 2e3bf84 Select different name server endpoints if failed to get topic
route.
new 6e380e4 Fix typo
new 70bbd1f Bugfix: add message to inflight set after removed from
pending set
new 32986fe Update to the lastet IDL
new 3423015 Polish code
new 39cdac9 Add javadocs
new 5bdac8c Polish code
new 549fb7c Revert "Polish code"
new f10f57a Shade apache commons
new 4e8f7fb Shutdown the rpcClient
new f579b2d Shade slf4j
new caa5570 Allow user set sts token manually
new fb09038 Polish code
new 0ce95aa synchronize process queue anyway even the remote assignments
is empty
new 0935058 Update messageId when message changed
new da63572 Prevent channel was garbage collected before shutdown
new ced111b Block #shutdown until all resources are released
new b5c30cf Never check deliveryAttempt is positive or not
new 78a8b17 Remove MessageExt#isExpired
new 93af0f7 Bugfix: consume message using scheduler
new a811e9d Fix ut
new dcecc51 Reset bornTime and messageId while message changed
new a922abf Mark message as corrupted while failed to uncompress
message's body
new 1c3b369 Polish code
new 8a47d2e Adapt logback configuration for windows
new 909e212 Fix logs path
new 6d46474 Polish logback
new 47bb2fb Redirect JUL logging to slf4j
new 8dbc430 Move JUL bridge to static code block
new 4eed9be Polish code
new be5d8fc Stop to receive/pull message after impl is stopped
new b3c351d Add pid to log
new c237dca Add more logs
new a874be9 Log sdk version
new 21dd233 Add manifest entry
new 978283f Polish log
new 5e8cde2 Set default value for sdk wrapper version
new 4f2f028 Add mid for multi-plexing ping-pong
new 82484f4 Add profile to allow generate bytecode for java8
new 0bb0fae Print log when resend message successfully
new ab80ad8 No need to send message any more when it is timeout
new a3a0f8f Add comments
new 682fd67 Rename publishInfo to topicSendingPartitions
new e9caf3b Remove ugly 'DefaultMQ' prefix in implement
new e864056 Polish code
new 620a74b Update version to 5.0.0-SNAPSHOT
new d44ce18 Add color for console appender
new 237b093 Polish code
new d962e4a Polish code
new 06bee6a Provide wrapper for simple future
new ce62ca4 Simplify interface of ProcessQueue
new 7cd65b4 Polish code
new ff5770f Shorten clientId's length
new 67dd93d Add checkNotNull for setter
new 08c9e17 Add transaction resolution to message interceptor
new 3e59c09 Polish code
new 0741d92 Polish code
new 707b744 Add batchSize to message tracing attribute
new 8c80af8 Polish code
new f6380a1 Update readme
new 8903265 Fix spotbugs issue
new 52d2138 Polish code
new 7e43a8b Fix a series of bugs
new 4d2f6b2 Adjust heartbeat frequency
new cf44389 Polish code
new b05f371 Polish code
new bce1c15 Add ut
new 64d7804 Add protocol version to gRPC header
new d99545b Add ut
new bdeea2b Refresh sts credentials asynchronously
new b1ca5bb Remove useless code
new 977d345 Remove useless dependency
new 39d3576 Set default value for tag and messageGroup
new 5a4f05f Set default value for system properties
new fa055b0 set bornHost in message's constructor
new 563b186 Add client id to tracing attribute
new 1e46c94 Fix error prone issue
new 2f35063 Bugfix: observer not registered for present client manager
new 0052ca2 Supply ut for ClientManagerFactory
new 2e8e211 Extract nextOffsetRecord from ProcessQueueImpl
new 10bab84 Add ut
new 35488ff Adapt for windows platform
new 97104fb Change metadata properties file's name
new 78953ef Polish code of message tracing
new 504c6bb Polish log
new 72177ea Add log for multiplexing
new 8ffaafd Add ut
new 05e1d9b Execute precondition check before sending message
new 79df334 Throw exception when starts the client repeatedly
new 87fab47 Polish code
new 0f8d436 Polish code
new fbeeaf6 Remove deprecated code
new 1d5ff3c Bugfix: add mid for verifyConsumptionResponse
new afe21af Fix typo
new ad8fa9a Polish code
new 989c7fa Extract dispatcher from consume service
new 1613ca4 Need to signal to dispatch message immediately because of the
end of last message's life cycle.
new d1a3038 Polish code
new 0f6a434 Delete pull consumer
new 1f6a013 Delete useless constructor
new 062e125 Update to the latest IDL
new 828bdc4 Remove TODO
new 931b52a Fix typo
new 0440202 Fix typo
new 63349d9 Add deprecated constructor for message queue
new ace3086 Apply guava IntMath
new 9f71ca7 Using guava immutable list to save topic route
new d7d2119 Apply guava optional
new dc60797 Polish code
new a04b7c4 Bugfix: optionalOffset#isPresent may throw NPE
new 6225d78 Polish code
new 6cf33d9 Add TODO
new 3bc0927 Polish code
new 4caeec7 Suppressing unnecessary warning
new 5955dfc Add AbstractClient
new 40d8007 Apply guava AbstractIdleService
new a687894 Rename arn in header to namespace
new 84075a4 Move MessageIdGenerator to thin-client module
new 5ede36d Provide shade and noshade thin-client jar
new 9a41779 Only dispatch once when signal
new 30840d0 Polish code
new 0167d7c Polish code
new 5fab2b1 Parse wrapper.version from
rocketmq.wrapper.metadata.properties
new 16f8525 Polish code
new 22add35 Polish reademe
new f517c86 Refactor message trace
new c2824d7 Polish code
new 1446252 Add ut
new 02a2c67 Add more ut
new 5c96221 Add more comments
new c51f008 Bugfix: signal dispatcher periodically
new d2aab83 Supply requestId for gRPC header
new f8d1d0c Fix checkstyle
new 5eea939 Remove repeated code
new 389ec80 Update to the latest IDL
new 16cb409 Notify client's termination when shutdown
new fbbff54 Add shutdown hook for ClientImpl
new f9bdabf Add logs when client is terminated
new 3740a05 Bugfix: await client service terminated
new 49a301b Polish code
new eabf167 Fix typo
new d95cdd0 Add namespace for log
new 5cabce3 Polish code
new 4e46f04 Bugfix: add requestId to header anyway
new 0a30be1 Format pom.xml
new 98f6b3c Scan assignments after heartbeat success
new be21d74 Make ClientImpl#updateTopicRouteCache synchronized
new d2d7010 Polish code
new 2e68aed Polish code
new 08e562f Remove TODO
new 12df31a Fix typo
new 59eeb34 Add UT
new 5a647cd Add clientId to log
new 46dbc11 Using UUID as requestId
new df8a88b Bugfix: wrong timeunit for AbstractOffsetStore
new c387f1c Polish code
new b641357 Remove useless ReceiveStatus
new 054bd1f Rename parameter
new a6b34ac Refactor AbstractOffsetStore
new cc4afc3 Update message attributes according to the community's opinion
new 1c15577 Polish code
new d63901b Print log when shutdown hook is invoked
new df31020 Catch exception while update offset
new 9ee51cf Add namespace to log
new deef512 Print logs when offset not found for broadcasting consumption
new 3514f69 MessageQueue#equals: compre partition only when it exists
new e60e90d Polish code
new f2e8c97 Bugfix: update offset after query offset from remote
new b0a08ba Delete useless code
new 82600ba Add UT
new f9487cc Polish code
new 1d98e49 Set code to DEADLINE_EXCEEDED_VALUE while consumption is
timeout
new a7b81c6 Polish code
new 49372d4 Add service.name to tracing attributes
new 439ec59 Add logs when exporter endpoints is updated
new 86a1be5 Polish code
new fddd7d6 Fix typo
new d8408de Using system current millis as end time
new ea69636 Bugfix: shutdown the message tracer when client is shutdown
new 9aa824c Polish code
new 2e4634f Update dependecies's version
new 5de563f Update reademe
new 229fcd7 Remove useless proto in shaded jar
new 61d6749 Add client shade module
new a7e14ff Update artifact version to 5.0.0
new 2b1ae5e Adjust stats frequency
new b23d3f8 Set maxInboundMessageSize manually
new a413626 Adjust grpc max message size
new 91b4149 Polish code
new 58ddb94 Remove submodule
new a5c0336 Make it adapt with the newest IDL
new fbe9967 Adjust receive and pull delay
new e55db28 Shutdown async worker after channel is shutdown
new c5ed761 Raise the coverage threshold
new adcd1f3 Polish code
new de9d868 Polish code
new 9cdd55b Enrich the log
new 3020bb7 Enrich the log
new 4c7d49d Update readme
new 6fbf59d Enrich the log
new 9ef62ce Update to the latest IDL
new 9133d7f Polish code
new 95c60d4 Polish code
new 6977d29 Ignore message for consumption verification if it is corrupted
new 579d57b Add ut
new 1305c81 Fill empty route cache when topic not found
new e15cfd7 Bugfix: set commandId in reportMessageConsumptionResultRequest
new 5bc0682 Polish code
new bf4de2c Polish code
new 084deee Bugfix: set status for process span
new a6365c9 Update version to 5.0.0-alpha
new 56293ec Polish code
new 5daae28 Update version to alpha1
new e5ca63a Update to latest IDL
new 5add032 Polish code
new 303e425 Order rocketmq trace attributes
new 383b1d8 Bugfix: forget to set name server string
new 2ae43e6 Add service.version for tracing
new f2f8e97 Add MessageModel to tracing attributes
new 3e53920 Fix typo
new e31e25c Dump vertion to 5.0.0-alpha2
new 2ac8867 Update submodule url
new a8636a1 Remove existed proto directory
new e962331 Update git badge
new 0f521bc Fix typo
new 1fc4d3c Polish comments
new 0e8623f Add UniversalAttributes for receive span
new abd2cca Block sensitive data in process.command_line
new 5fbbb6b Bump version to 5.0.0-alpha3
new c17b31d Bugfix: forget to shutdown command executor
new 53a4327 Fix #42407189, there may be threads that acquire the write
lock before the read lock is released during the health check, which will lead
to deadlock
new 9c8534a Polish code about creation of process queue
new 0f1373e Bugfix: Prematurely exited when the process queeu already
existed
new ee7adcf Integrate current repo with rocketmq clients
new 35c4ce1 Merge branch 'java'
The 460 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitlab-ci.yml | 10 +
.gitmodules | 3 +
java_old/README.md | 84 +
java_old/docs/Design.md | 0
java_old/docs/Trace.md | 0
java_old/pom.xml | 393 ++
java_old/rocketmq-client-shaded/pom.xml | 169 +
java_old/rocketmq-client/pom.xml | 70 +
.../rocketmq/client/consumer/ConsumeContext.java | 10 +-
.../rocketmq/client/consumer/ConsumeFromWhere.java | 22 +-
.../rocketmq/client/consumer/ConsumeStatus.java | 12 +-
.../client/consumer/DefaultMQPushConsumer.java | 384 ++
.../rocketmq/client/consumer/MessageModel.java | 35 +-
.../client/consumer/PullMessageResult.java | 59 +
.../rocketmq/client/consumer/PullStatus.java | 31 +-
.../client/consumer/ReceiveMessageResult.java | 62 +
.../rocketmq/client/consumer/ReceiveStatus.java | 30 +-
.../client/consumer/filter/ExpressionType.java | 5 +-
.../client/consumer/filter/FilterExpression.java | 83 +
.../client/consumer/listener/MessageListener.java | 20 +-
.../listener/MessageListenerConcurrently.java | 12 +-
.../consumer/listener/MessageListenerOrderly.java | 12 +-
.../consumer/listener/MessageListenerType.java | 11 +-
.../rocketmq/client/exception/ClientException.java | 46 +
.../rocketmq/client/exception/ErrorCode.java | 21 +-
.../rocketmq/client/exception/ServerException.java | 15 +-
.../org/apache/rocketmq/client/impl/Client.java | 32 +-
.../apache/rocketmq/client/impl/ClientConfig.java | 178 +
.../apache/rocketmq/client/impl/ClientImpl.java | 846 ++++
.../apache/rocketmq/client/impl/ClientManager.java | 303 ++
.../rocketmq/client/impl/ClientManagerFactory.java | 108 +
.../rocketmq/client/impl/ClientManagerImpl.java | 574 +++
.../org/apache/rocketmq/client/impl/Signature.java | 133 +
.../client/impl/consumer/AbstractOffsetStore.java | 113 +
.../rocketmq/client/impl/consumer/Assignment.java | 59 +
.../impl/consumer/ConsumeConcurrentlyService.java | 109 +
.../impl/consumer/ConsumeOrderlyService.java | 76 +
.../client/impl/consumer/ConsumeService.java | 139 +
.../rocketmq/client/impl/consumer/ConsumeTask.java | 91 +
.../client/impl/consumer/ConsumerImpl.java | 226 ++
.../client/impl/consumer/NextOffsetRecord.java | 95 +
.../client/impl/consumer/OffsetRecord.java | 79 +
.../rocketmq/client/impl/consumer/OffsetStore.java | 54 +
.../client/impl/consumer/ProcessQueue.java | 101 +
.../client/impl/consumer/ProcessQueueImpl.java | 1162 ++++++
.../client/impl/consumer/PushConsumerImpl.java | 1137 ++++++
.../client/impl/consumer/TopicAssignments.java | 82 +
.../client/impl/producer/ProducerImpl.java | 877 ++++
.../impl/producer/SendingTopicRouteData.java | 141 +
.../apache/rocketmq/client/message/Message.java | 181 +
.../apache/rocketmq/client/message/MessageExt.java | 153 +
.../rocketmq/client/message/MessageHookPoint.java | 93 +
.../client/message/MessageHookPointStatus.java | 16 +-
.../client/message/MessageIdGenerator.java | 101 +
.../rocketmq/client/message/MessageImpl.java | 107 +
.../client/message/MessageImplAccessor.java | 188 +
.../client/message/MessageInterceptor.java | 15 +-
.../client/message/MessageInterceptorContext.java | 134 +
.../rocketmq/client/message/MessageQueue.java | 94 +
.../rocketmq/client/message/protocol/Digest.java | 25 +-
.../client/message/protocol/DigestType.java | 12 +-
.../rocketmq/client/message/protocol/Encoding.java | 11 +-
.../client/message/protocol/MessageType.java | 20 +-
.../rocketmq/client/message/protocol/Resource.java | 75 +
.../client/message/protocol/SystemAttribute.java | 275 ++
.../apache/rocketmq/client/misc/Dispatcher.java | 113 +
.../org/apache/rocketmq/client/misc/MixAll.java | 46 +-
.../apache/rocketmq/client/misc/TopAddressing.java | 75 +
.../apache/rocketmq/client/misc/Validators.java | 107 +
.../client/producer/DefaultMQProducer.java | 335 ++
.../client/producer/MessageGroupQueueSelector.java | 22 +-
.../client/producer/MessageQueueSelector.java | 14 +-
.../rocketmq/client/producer/SendCallback.java | 22 +-
.../rocketmq/client/producer/SendResult.java | 65 +
.../rocketmq/client/producer/SendStatus.java | 20 +-
.../rocketmq/client/producer/Transaction.java | 21 +-
.../client/producer/TransactionChecker.java | 12 +-
.../rocketmq/client/producer/TransactionImpl.java | 51 +
.../client}/producer/TransactionResolution.java | 25 +-
.../rocketmq/client/remoting/AuthInterceptor.java | 67 +
.../rocketmq/client/remoting/Credentials.java | 76 +
.../client/remoting/CredentialsProvider.java | 12 +-
.../client/remoting/IpNameResolverFactory.java | 85 +
.../client/remoting/LoggingInterceptor.java | 66 +
.../apache/rocketmq/client/remoting/RpcClient.java | 290 ++
.../rocketmq/client/remoting/RpcClientImpl.java | 252 ++
.../client/remoting/StaticCredentialsProvider.java | 16 +-
.../client/remoting/StsCredentialsProvider.java | 183 +
.../apache/rocketmq/client/remoting/TlsHelper.java | 46 +
.../org/apache/rocketmq/client/route/Address.java | 79 +
.../rocketmq/client/route/AddressScheme.java | 40 +-
.../org/apache/rocketmq/client/route/Broker.java | 73 +
.../apache/rocketmq/client/route/Endpoints.java | 144 +
.../apache/rocketmq/client/route/Partition.java | 104 +
.../apache/rocketmq/client/route/Permission.java | 71 +
.../rocketmq/client/route/TopicRouteData.java | 116 +
.../rocketmq/client/trace/MessagingAttributes.java | 104 +
.../rocketmq/client/trace/ResourceAttributes.java | 176 +
.../rocketmq/client/trace/RocketmqAttributes.java | 65 +
.../rocketmq/client/trace/RocketmqOperation.java | 25 +-
.../client/trace/TraceEndpointsProvider.java | 18 +-
.../rocketmq/client/trace/TraceResource.java | 167 +
.../client/trace/TracingMessageInterceptor.java | 439 ++
.../rocketmq/client/trace/TracingUtility.java | 138 +
.../src/main/resources/rocketmq.logback.xml | 38 +
.../client/consumer/DefaultMQPushConsumerTest.java | 278 ++
.../consumer/filter/FilterExpressionTest.java | 88 +
.../rocketmq/client/impl/ClientImplTest.java | 116 +
.../client/impl/ClientManagerFactoryTest.java | 149 +
.../client/impl/ClientManagerImplTest.java | 171 +
.../apache/rocketmq/client/impl/SignatureTest.java | 64 +
.../consumer/ConsumeConcurrentlyServiceTest.java | 101 +
.../impl/consumer/ConsumeOrderlyServiceTest.java | 97 +
.../client/impl/consumer/ConsumeTaskTest.java | 99 +
.../client/impl/consumer/ConsumerImplTest.java | 209 +
.../client/impl/consumer/NextOffsetRecordTest.java | 101 +
.../client/impl/consumer/OffsetRecordTest.java | 50 +
.../client/impl/consumer/ProcessQueueImplTest.java | 502 +++
.../client/impl/consumer/PushConsumerImplTest.java | 317 ++
.../client/impl/producer/ProducerImplTest.java | 444 +++
.../impl/producer/SendingTopicRouteDataTest.java | 217 +
.../client/message/MessageIdGeneratorTest.java | 18 +-
.../rocketmq/client/message/MessageQueueTest.java | 55 +
.../rocketmq/client/message/MessageTest.java | 83 +
.../apache/rocketmq/client/misc/MixAllTest.java | 16 +-
.../rocketmq/client/misc/TopAddressingTest.java | 52 +-
.../rocketmq/client/misc/ValidatorsTest.java | 128 +
.../client/producer/DefaultMQProducerTest.java | 18 +-
.../rocketmq/client/producer/SendResultTest.java | 54 +
.../client/producer/TransactionImplTest.java | 90 +
.../rocketmq/client/remoting/CredentialsTest.java | 96 +
.../client/remoting/RpcClientImplTest.java | 19 +-
.../remoting/StaticCredentialsProviderTest.java | 39 +
.../remoting/StsCredentialsProviderTest.java | 135 +
.../rocketmq/client/route/PermissionTest.java | 41 +-
.../org/apache/rocketmq/client/tools/TestBase.java | 384 ++
.../trace/TracingMessageInterceptorTest.java | 341 ++
.../rocketmq/client/trace/TracingUtilityTest.java | 50 +
.../src/test/resources/rocketmq.logback-test.xml | 12 +
java_old/rocketmq-proto/pom.xml | 90 +
.../java/apache/rocketmq/v1/AckMessageRequest.java | 1384 +++++++
.../rocketmq/v1/AckMessageRequestOrBuilder.java | 83 +
.../apache/rocketmq/v1/AckMessageResponse.java | 607 +++
.../rocketmq/v1/AckMessageResponseOrBuilder.java | 24 +
.../src/main/java/apache/rocketmq/v1/Address.java | 621 +++
.../java/apache/rocketmq/v1/AddressOrBuilder.java | 27 +
.../java/apache/rocketmq/v1/AddressScheme.java | 122 +
.../main/java/apache/rocketmq/v1/AdminGrpc.java | 275 ++
.../main/java/apache/rocketmq/v1/Assignment.java | 607 +++
.../apache/rocketmq/v1/AssignmentOrBuilder.java | 24 +
.../src/main/java/apache/rocketmq/v1/Broker.java | 941 +++++
.../java/apache/rocketmq/v1/BrokerOrBuilder.java | 76 +
.../apache/rocketmq/v1/ChangeLogLevelRequest.java | 650 +++
.../v1/ChangeLogLevelRequestOrBuilder.java | 20 +
.../apache/rocketmq/v1/ChangeLogLevelResponse.java | 557 +++
.../v1/ChangeLogLevelResponseOrBuilder.java | 21 +
.../apache/rocketmq/v1/ConsumeMessageType.java | 113 +
.../main/java/apache/rocketmq/v1/ConsumeModel.java | 113 +
.../java/apache/rocketmq/v1/ConsumePolicy.java | 131 +
.../main/java/apache/rocketmq/v1/ConsumerData.java | 1434 +++++++
.../apache/rocketmq/v1/ConsumerDataOrBuilder.java | 96 +
.../java/apache/rocketmq/v1/DeadLetterPolicy.java | 521 +++
.../rocketmq/v1/DeadLetterPolicyOrBuilder.java | 21 +
.../src/main/java/apache/rocketmq/v1/Digest.java | 683 ++++
.../java/apache/rocketmq/v1/DigestOrBuilder.java | 32 +
.../main/java/apache/rocketmq/v1/DigestType.java | 152 +
.../src/main/java/apache/rocketmq/v1/Encoding.java | 113 +
.../apache/rocketmq/v1/EndTransactionRequest.java | 1429 +++++++
.../v1/EndTransactionRequestOrBuilder.java | 82 +
.../apache/rocketmq/v1/EndTransactionResponse.java | 607 +++
.../v1/EndTransactionResponseOrBuilder.java | 24 +
.../main/java/apache/rocketmq/v1/Endpoints.java | 866 ++++
.../apache/rocketmq/v1/EndpointsOrBuilder.java | 44 +
.../java/apache/rocketmq/v1/FilterExpression.java | 653 +++
.../rocketmq/v1/FilterExpressionOrBuilder.java | 32 +
.../main/java/apache/rocketmq/v1/FilterType.java | 113 +
.../v1/ForwardMessageToDeadLetterQueueRequest.java | 1337 +++++++
...rdMessageToDeadLetterQueueRequestOrBuilder.java | 87 +
.../ForwardMessageToDeadLetterQueueResponse.java | 607 +++
...dMessageToDeadLetterQueueResponseOrBuilder.java | 24 +
.../apache/rocketmq/v1/HealthCheckRequest.java | 745 ++++
.../rocketmq/v1/HealthCheckRequestOrBuilder.java | 36 +
.../apache/rocketmq/v1/HealthCheckResponse.java | 607 +++
.../rocketmq/v1/HealthCheckResponseOrBuilder.java | 24 +
.../java/apache/rocketmq/v1/HeartbeatRequest.java | 1119 ++++++
.../rocketmq/v1/HeartbeatRequestOrBuilder.java | 59 +
.../java/apache/rocketmq/v1/HeartbeatResponse.java | 607 +++
.../rocketmq/v1/HeartbeatResponseOrBuilder.java | 24 +
.../src/main/java/apache/rocketmq/v1/MQAdmin.java | 67 +
.../src/main/java/apache/rocketmq/v1/MQDomain.java | 283 ++
.../main/java/apache/rocketmq/v1/MQService.java | 654 +++
.../src/main/java/apache/rocketmq/v1/Message.java | 1237 ++++++
.../java/apache/rocketmq/v1/MessageOrBuilder.java | 119 +
.../main/java/apache/rocketmq/v1/MessageType.java | 157 +
.../apache/rocketmq/v1/MessagingServiceGrpc.java | 1900 +++++++++
.../apache/rocketmq/v1/NackMessageRequest.java | 1337 +++++++
.../rocketmq/v1/NackMessageRequestOrBuilder.java | 87 +
.../apache/rocketmq/v1/NackMessageResponse.java | 607 +++
.../rocketmq/v1/NackMessageResponseOrBuilder.java | 24 +
.../main/java/apache/rocketmq/v1/NoopCommand.java | 419 ++
.../apache/rocketmq/v1/NoopCommandOrBuilder.java | 9 +
.../v1/NotifyClientTerminationRequest.java | 1054 +++++
.../NotifyClientTerminationRequestOrBuilder.java | 53 +
.../v1/NotifyClientTerminationResponse.java | 607 +++
.../NotifyClientTerminationResponseOrBuilder.java | 24 +
.../main/java/apache/rocketmq/v1/Partition.java | 955 +++++
.../apache/rocketmq/v1/PartitionOrBuilder.java | 56 +
.../main/java/apache/rocketmq/v1/Permission.java | 131 +
.../apache/rocketmq/v1/PollCommandRequest.java | 1405 +++++++
.../rocketmq/v1/PollCommandRequestOrBuilder.java | 77 +
.../apache/rocketmq/v1/PollCommandResponse.java | 1536 +++++++
.../rocketmq/v1/PollCommandResponseOrBuilder.java | 119 +
.../rocketmq/v1/PrintThreadStackTraceCommand.java | 557 +++
.../v1/PrintThreadStackTraceCommandOrBuilder.java | 21 +
.../main/java/apache/rocketmq/v1/ProducerData.java | 607 +++
.../apache/rocketmq/v1/ProducerDataOrBuilder.java | 24 +
.../apache/rocketmq/v1/PullMessageRequest.java | 1438 +++++++
.../rocketmq/v1/PullMessageRequestOrBuilder.java | 93 +
.../apache/rocketmq/v1/PullMessageResponse.java | 1153 ++++++
.../rocketmq/v1/PullMessageResponseOrBuilder.java | 66 +
.../apache/rocketmq/v1/QueryAssignmentRequest.java | 1169 ++++++
.../v1/QueryAssignmentRequestOrBuilder.java | 78 +
.../rocketmq/v1/QueryAssignmentResponse.java | 958 +++++
.../v1/QueryAssignmentResponseOrBuilder.java | 48 +
.../java/apache/rocketmq/v1/QueryOffsetPolicy.java | 146 +
.../apache/rocketmq/v1/QueryOffsetRequest.java | 891 +++++
.../rocketmq/v1/QueryOffsetRequestOrBuilder.java | 50 +
.../apache/rocketmq/v1/QueryOffsetResponse.java | 672 ++++
.../rocketmq/v1/QueryOffsetResponseOrBuilder.java | 30 +
.../java/apache/rocketmq/v1/QueryRouteRequest.java | 829 ++++
.../rocketmq/v1/QueryRouteRequestOrBuilder.java | 39 +
.../apache/rocketmq/v1/QueryRouteResponse.java | 958 +++++
.../rocketmq/v1/QueryRouteResponseOrBuilder.java | 48 +
.../apache/rocketmq/v1/ReceiveMessageRequest.java | 1910 +++++++++
.../v1/ReceiveMessageRequestOrBuilder.java | 134 +
.../apache/rocketmq/v1/ReceiveMessageResponse.java | 1334 +++++++
.../v1/ReceiveMessageResponseOrBuilder.java | 78 +
.../v1/RecoverOrphanedTransactionCommand.java | 745 ++++
...RecoverOrphanedTransactionCommandOrBuilder.java | 36 +
.../v1/ReportMessageConsumptionResultRequest.java | 817 ++++
...rtMessageConsumptionResultRequestOrBuilder.java | 54 +
.../v1/ReportMessageConsumptionResultResponse.java | 607 +++
...tMessageConsumptionResultResponseOrBuilder.java | 24 +
.../rocketmq/v1/ReportThreadStackTraceRequest.java | 695 ++++
.../v1/ReportThreadStackTraceRequestOrBuilder.java | 33 +
.../v1/ReportThreadStackTraceResponse.java | 607 +++
.../ReportThreadStackTraceResponseOrBuilder.java | 24 +
.../src/main/java/apache/rocketmq/v1/Resource.java | 730 ++++
.../java/apache/rocketmq/v1/ResourceOrBuilder.java | 43 +
.../java/apache/rocketmq/v1/ResponseCommon.java | 1547 ++++++++
.../rocketmq/v1/ResponseCommonOrBuilder.java | 99 +
.../apache/rocketmq/v1/SendMessageRequest.java | 795 ++++
.../rocketmq/v1/SendMessageRequestOrBuilder.java | 39 +
.../apache/rocketmq/v1/SendMessageResponse.java | 883 +++++
.../rocketmq/v1/SendMessageResponseOrBuilder.java | 48 +
.../java/apache/rocketmq/v1/SubscriptionEntry.java | 795 ++++
.../rocketmq/v1/SubscriptionEntryOrBuilder.java | 39 +
.../java/apache/rocketmq/v1/SystemAttribute.java | 4173 ++++++++++++++++++++
.../rocketmq/v1/SystemAttributeOrBuilder.java | 463 +++
.../v1/VerifyMessageConsumptionCommand.java | 745 ++++
.../VerifyMessageConsumptionCommandOrBuilder.java | 36 +
java_old/rocketmq-utility/pom.xml | 39 +
.../apache/rocketmq/utility/ExecutorServices.java | 15 +-
.../apache/rocketmq/utility/HttpTinyClient.java | 125 +
.../org/apache/rocketmq/utility/MetadataUtils.java | 66 +
.../rocketmq/utility/RequestIdGenerator.java | 16 +-
.../apache/rocketmq/utility/SimpleCallable.java | 13 +-
.../org/apache/rocketmq/utility/SimpleFuture.java | 52 +
.../apache/rocketmq/utility/ThreadFactoryImpl.java | 41 +-
.../java/org/apache/rocketmq/utility/UtilAll.java | 279 ++
.../rocketmq.metadata.properties | 1 +
.../rocketmq/utility/HttpTinyClientTest.java | 78 +
.../apache/rocketmq/utility/HttpTinyServer.java | 105 +
.../apache/rocketmq/utility/MetadataUtilsTest.java | 21 +-
.../apache/rocketmq/utility/SimpleFutureTest.java | 47 +-
.../rocketmq/utility/ThreadFactoryImplTest.java | 45 +-
.../org/apache/rocketmq/utility/UtilAllTest.java | 93 +
.../resources/rocketmq.wrapper.metadata.properties | 1 +
java_old/style/checkstyle.xml | 394 ++
java_old/style/intellij-codestyle.xml | 67 +
java_old/style/spotbugs-suppressions.xml | 24 +
281 files changed, 78314 insertions(+), 463 deletions(-)
create mode 100644 .gitlab-ci.yml
create mode 100644 .gitmodules
create mode 100644 java_old/README.md
create mode 100644 java_old/docs/Design.md
create mode 100644 java_old/docs/Trace.md
create mode 100644 java_old/pom.xml
create mode 100644 java_old/rocketmq-client-shaded/pom.xml
create mode 100644 java_old/rocketmq-client/pom.xml
copy csharp/rocketmq-client-csharp/Permission.cs =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/ConsumeContext.java
(91%)
copy
java/client-apis/src/main/java/client/apis/producer/TransactionResolution.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/ConsumeFromWhere.java
(66%)
copy java/client-apis/src/main/java/client/apis/message/MessageIdVersion.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/ConsumeStatus.java
(82%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
copy java/client-apis/src/main/java/client/apis/retry/RetryPolicy.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/MessageModel.java
(55%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/PullMessageResult.java
copy
java/client-apis/src/main/java/client/apis/producer/TransactionResolution.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
(51%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/ReceiveMessageResult.java
copy
java/client-apis/src/main/java/client/apis/producer/TransactionResolution.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/ReceiveStatus.java
(54%)
copy
java/client-apis/src/main/java/client/apis/consumer/FilterExpressionType.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/filter/ExpressionType.java
(92%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/filter/FilterExpression.java
copy cpp/src/main/cpp/rocketmq/tests/TimeTest.cpp =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
(66%)
copy
java/client-apis/src/main/java/client/apis/exception/ResourceNotFoundException.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
(71%)
copy
java/client-apis/src/main/java/client/apis/exception/ResourceNotFoundException.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
(72%)
copy java/client-apis/src/main/java/client/apis/MessageQueue.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerType.java
(86%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/exception/ClientException.java
copy cpp/src/main/cpp/base/ErrorCode.cpp =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/exception/ErrorCode.java
(70%)
copy
java/client-apis/src/main/java/client/apis/exception/ResourceNotMatchException.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/exception/ServerException.java
(69%)
copy
java/client-apis/src/main/java/client/apis/producer/TransactionResolution.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/Client.java
(54%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/ClientConfig.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/ClientImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/ClientManager.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/ClientManagerFactory.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/ClientManagerImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/Signature.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/AbstractOffsetStore.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/Assignment.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeConcurrentlyService.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeOrderlyService.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeService.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeTask.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumerImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/NextOffsetRecord.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/OffsetRecord.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/OffsetStore.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueueImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/PushConsumerImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/consumer/TopicAssignments.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/producer/ProducerImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/impl/producer/SendingTopicRouteData.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/Message.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageExt.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageHookPoint.java
copy java/client-apis/src/main/java/client/apis/message/MessageIdVersion.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageHookPointStatus.java
(82%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageIdGenerator.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageImpl.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageImplAccessor.java
copy java/client-apis/src/main/java/client/apis/consumer/ConsumeResult.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageInterceptor.java
(74%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageInterceptorContext.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/MessageQueue.java
copy
java/client-apis/src/main/java/client/apis/StaticSessionCredentialsProvider.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/protocol/Digest.java
(57%)
copy java/client-apis/src/main/java/client/apis/MessageQueue.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/protocol/DigestType.java
(87%)
copy java/client-apis/src/main/java/client/apis/MessageQueue.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/protocol/Encoding.java
(88%)
copy
java/client-apis/src/main/java/client/apis/exception/NetworkException.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/protocol/MessageType.java
(72%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/protocol/Resource.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/message/protocol/SystemAttribute.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/misc/Dispatcher.java
copy csharp/tests/SequenceGeneratorTest.cs =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/misc/MixAll.java
(52%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/misc/TopAddressing.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/misc/Validators.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
copy
java/client-apis/src/main/java/client/apis/StaticSessionCredentialsProvider.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/MessageGroupQueueSelector.java
(57%)
copy cpp/src/main/cpp/base/ErrorCode.cpp =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java
(72%)
copy java/client-apis/src/main/java/client/apis/retry/RetryPolicy.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java
(66%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java
copy java/client-apis/src/main/java/client/apis/consumer/ConsumeResult.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java
(73%)
copy cpp/src/main/cpp/base/MessageExt.cpp =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/Transaction.java
(62%)
copy cpp/src/main/cpp/base/Tracing.cpp =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/TransactionChecker.java
(80%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/producer/TransactionImpl.java
copy {java/client-apis/src/main/java/client/apis =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client}/producer/TransactionResolution.java
(64%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/AuthInterceptor.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/Credentials.java
copy cpp/src/main/cpp/base/Tracing.cpp =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/CredentialsProvider.java
(79%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/IpNameResolverFactory.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/LoggingInterceptor.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/RpcClient.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/RpcClientImpl.java
copy
java/client-apis/src/main/java/client/apis/StaticSessionCredentialsProvider.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/StaticCredentialsProvider.java
(60%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/StsCredentialsProvider.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/remoting/TlsHelper.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/Address.java
copy
java/client-apis/src/main/java/client/apis/producer/TransactionResolution.java
=>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/AddressScheme.java
(51%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/Broker.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/Endpoints.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/Partition.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/Permission.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/route/TopicRouteData.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/MessagingAttributes.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/ResourceAttributes.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/RocketmqAttributes.java
copy
java/client-apis/src/main/java/client/apis/exception/TimeoutException.java =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/RocketmqOperation.java
(65%)
copy cpp/api/rocketmq/ExpressionType.h =>
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/TraceEndpointsProvider.java
(80%)
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/TraceResource.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/TracingMessageInterceptor.java
create mode 100644
java_old/rocketmq-client/src/main/java/org/apache/rocketmq/client/trace/TracingUtility.java
create mode 100644
java_old/rocketmq-client/src/main/resources/rocketmq.logback.xml
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/consumer/filter/FilterExpressionTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/ClientImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/ClientManagerFactoryTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/ClientManagerImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/SignatureTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeConcurrentlyServiceTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeOrderlyServiceTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeTaskTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumerImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/NextOffsetRecordTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/OffsetRecordTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/ProcessQueueImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/consumer/PushConsumerImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/producer/ProducerImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/impl/producer/SendingTopicRouteDataTest.java
copy csharp/rocketmq-client-csharp/IClient.cs =>
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/message/MessageIdGeneratorTest.java
(71%)
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/message/MessageQueueTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/message/MessageTest.java
copy csharp/rocketmq-client-csharp/IClient.cs =>
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/misc/MixAllTest.java
(76%)
copy cpp/src/main/cpp/remoting/include/QueueData.h =>
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/misc/TopAddressingTest.java
(54%)
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/misc/ValidatorsTest.java
copy
java/client-apis/src/main/java/client/apis/exception/NetworkException.java =>
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java
(62%)
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/producer/SendResultTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/producer/TransactionImplTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/remoting/CredentialsTest.java
copy csharp/rocketmq-client-csharp/IClient.cs =>
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/remoting/RpcClientImplTest.java
(66%)
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/remoting/StaticCredentialsProviderTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/remoting/StsCredentialsProviderTest.java
copy cpp/src/main/cpp/base/FilterExpression.cpp =>
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/route/PermissionTest.java
(53%)
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/tools/TestBase.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/trace/TracingMessageInterceptorTest.java
create mode 100644
java_old/rocketmq-client/src/test/java/org/apache/rocketmq/client/trace/TracingUtilityTest.java
create mode 100644
java_old/rocketmq-client/src/test/resources/rocketmq.logback-test.xml
create mode 100644 java_old/rocketmq-proto/pom.xml
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AckMessageRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AckMessageRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AckMessageResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AckMessageResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Address.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AddressOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AddressScheme.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AdminGrpc.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Assignment.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/AssignmentOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Broker.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/BrokerOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ChangeLogLevelRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ChangeLogLevelRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ChangeLogLevelResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ChangeLogLevelResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ConsumeMessageType.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ConsumeModel.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ConsumePolicy.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ConsumerData.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ConsumerDataOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/DeadLetterPolicy.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/DeadLetterPolicyOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Digest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/DigestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/DigestType.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Encoding.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/EndTransactionRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/EndTransactionRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/EndTransactionResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/EndTransactionResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Endpoints.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/EndpointsOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/FilterExpression.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/FilterExpressionOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/FilterType.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ForwardMessageToDeadLetterQueueResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HealthCheckRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HealthCheckRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HealthCheckResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HealthCheckResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HeartbeatRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HeartbeatRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HeartbeatResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/HeartbeatResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/MQAdmin.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/MQDomain.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/MQService.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Message.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/MessageOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/MessageType.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/MessagingServiceGrpc.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NackMessageRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NackMessageRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NackMessageResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NackMessageResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NoopCommand.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NoopCommandOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NotifyClientTerminationRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NotifyClientTerminationRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NotifyClientTerminationResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/NotifyClientTerminationResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Partition.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PartitionOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Permission.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PollCommandRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PollCommandRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PollCommandResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PollCommandResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PrintThreadStackTraceCommand.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PrintThreadStackTraceCommandOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ProducerData.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ProducerDataOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PullMessageRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PullMessageRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PullMessageResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/PullMessageResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryAssignmentRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryAssignmentRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryAssignmentResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryAssignmentResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryOffsetPolicy.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryOffsetRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryOffsetRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryOffsetResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryOffsetResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryRouteRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryRouteRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryRouteResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/QueryRouteResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReceiveMessageRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReceiveMessageRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReceiveMessageResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReceiveMessageResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/RecoverOrphanedTransactionCommand.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/RecoverOrphanedTransactionCommandOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportMessageConsumptionResultResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ReportThreadStackTraceResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/Resource.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ResourceOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ResponseCommon.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/ResponseCommonOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SendMessageRequest.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SendMessageRequestOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SendMessageResponse.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SendMessageResponseOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SubscriptionEntry.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SubscriptionEntryOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SystemAttribute.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/SystemAttributeOrBuilder.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/VerifyMessageConsumptionCommand.java
create mode 100644
java_old/rocketmq-proto/src/main/java/apache/rocketmq/v1/VerifyMessageConsumptionCommandOrBuilder.java
create mode 100644 java_old/rocketmq-utility/pom.xml
copy
java/client-apis/src/main/java/client/apis/exception/TimeoutException.java =>
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/ExecutorServices.java
(66%)
create mode 100644
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/HttpTinyClient.java
create mode 100644
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/MetadataUtils.java
copy
java/client-apis/src/main/java/client/apis/exception/NetworkException.java =>
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/RequestIdGenerator.java
(71%)
copy
java/client-apis/src/main/java/client/apis/exception/ResourceNotMatchException.java
=>
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/SimpleCallable.java
(75%)
create mode 100644
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/SimpleFuture.java
copy csharp/tests/SendResultTest.cs =>
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/ThreadFactoryImpl.java
(51%)
create mode 100644
java_old/rocketmq-utility/src/main/java/org/apache/rocketmq/utility/UtilAll.java
create mode 100644
java_old/rocketmq-utility/src/main/resources-filtered/rocketmq.metadata.properties
create mode 100644
java_old/rocketmq-utility/src/test/java/org/apache/rocketmq/utility/HttpTinyClientTest.java
create mode 100644
java_old/rocketmq-utility/src/test/java/org/apache/rocketmq/utility/HttpTinyServer.java
copy
java/client-apis/src/main/java/client/apis/exception/NetworkException.java =>
java_old/rocketmq-utility/src/test/java/org/apache/rocketmq/utility/MetadataUtilsTest.java
(69%)
copy csharp/tests/SequenceGeneratorTest.cs =>
java_old/rocketmq-utility/src/test/java/org/apache/rocketmq/utility/SimpleFutureTest.java
(52%)
copy csharp/tests/SequenceGeneratorTest.cs =>
java_old/rocketmq-utility/src/test/java/org/apache/rocketmq/utility/ThreadFactoryImplTest.java
(53%)
create mode 100644
java_old/rocketmq-utility/src/test/java/org/apache/rocketmq/utility/UtilAllTest.java
create mode 100644
java_old/rocketmq-utility/src/test/resources/rocketmq.wrapper.metadata.properties
create mode 100644 java_old/style/checkstyle.xml
create mode 100644 java_old/style/intellij-codestyle.xml
create mode 100644 java_old/style/spotbugs-suppressions.xml
