rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ifplu...@apache.org
Subject [rocketmq-client-cpp] branch re_dev updated (7eef639 -> 8402eb0)
Date Tue, 29 Dec 2020 03:36:17 GMT
This is an automated email from the ASF dual-hosted git repository.

ifplusor pushed a change to branch re_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git.


    from 7eef639  fixed uniqMsgId for batch result.
     new 3636d60  Catch exception when resolve domain failed
     new 8e6c3b9  remove redundant code
     new c595776  fix(executor): incorrect param pass to forward
     new 4d79bcf  refactor(MQMessage): MQMessage[Ext] as reference
     new f0cce44  refactor: replace MemoryBlock with ByteArray
     new c3d9a3c  feat(request-reply): more request interface
     new 28a4727  refactor(consumer): remove const in consumeMessage
     new dc782f2  fix: use invalid ByteArrayRef after call std::move
     new 15a8b0b  fix: missing include functional
     new cb27896  refactor: remove dynamic exception specifications
     new e1068cb  fix: check the lock of process queue is expired
     new 6bf1639  style: follow Chromium c++ style
     new 793d13a  style: rename accessors and mutators
     new 9c1c689  style: protocol
     new a281df9  refactor: MQMessageExt::from_list
     new a5aa61e  refactor: concurrent_queue
     new 505ea47  refactor: NamespaceUtil
     new 444dc14  refactor: DefaultMQPushConsumer
     new 67c55f8  refactor: ExpressionType
     new 99b18ab  refactor: MessageSelector
     new 3a805ec  refactor: RemoteBrokerOffsetStore::persistAll
     new c1c2eb8  refactor: PullAPIWrapper::processPullResult
     new 03f31cf  refactor: ConsumerRunningInfo::encode
     new 2b0b540  fix: version of RemotingCommand
     new 2af15ea  refactor: logger
     new a750efa  feat: DefaultLitePullConsumer
     new 4ace548  style: fix GET_ROUTEINFO_BY_TOPIC
     new 9a30e84  refactor: lock/unlock in RebalanceImpl
     new 8402eb0  chore: update for clangd

The 29 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:
 .gitignore                                         |   3 +
 example/ArgHelper.cpp                              |  20 +-
 example/ArgHelper.h                                |   9 +-
 example/AsyncProducer.cpp                          |  32 +-
 example/BatchProducer.cpp                          |  32 +-
 example/CMakeLists.txt                             |   2 +-
 example/OrderlyProducer.cpp                        |  26 +-
 example/OrderlyPushConsumer.cpp                    |  22 +-
 ...llConsumeMessage.c => PullConsumeMessage.c.bak} |   0
 example/{PullConsumer.cpp => PullConsumer.cpp.bak} |  19 +-
 example/PushConsumer.cpp                           |  30 +-
 example/RequestReply.cpp                           |  45 +-
 example/SendDelayMsg.cpp                           |  15 +-
 example/SyncProducer.cpp                           |  26 +-
 example/TransactionProducer.cpp                    |  30 +-
 example/common.h                                   |  26 +-
 include/AllocateMQStrategy.h                       |  11 +-
 include/Array.h                                    |  85 ++
 src/protocol/KVTable.h => include/ByteArray.h      |  30 +-
 include/ClientRPCHook.h                            |  12 +-
 include/CommandCustomHeader.h                      |  12 +-
 include/ConsumeType.h                              |   6 +-
 include/DataBlock.h                                | 219 -----
 include/DefaultLitePullConsumer.h                  |  79 ++
 include/DefaultLitePullConsumerConfig.h            |  85 ++
 include/DefaultLitePullConsumerConfigProxy.h       | 175 ++++
 include/DefaultMQProducer.h                        |  67 +-
 include/DefaultMQProducerConfig.h                  |  44 +-
 include/DefaultMQProducerConfigProxy.h             |  90 ++-
 include/DefaultMQPullConsumer.h                    |  81 --
 include/DefaultMQPullConsumerConfig.h              |  42 -
 include/DefaultMQPullConsumerConfigProxy.h         |  48 --
 include/DefaultMQPushConsumer.h                    |  30 +-
 include/DefaultMQPushConsumerConfig.h              |  58 +-
 include/DefaultMQPushConsumerConfigProxy.h         | 102 ++-
 .../ExpressionType.h                               |  20 +-
 include/LitePullConsumer.h                         |  79 ++
 include/MQAdmin.h                                  |  10 +-
 include/MQClientConfig.h                           |  46 +-
 include/MQClientConfigProxy.h                      |  70 +-
 include/MQConsumer.h                               |  45 --
 include/{MQClientException.h => MQException.h}     |  57 +-
 include/MQMessage.h                                | 120 +--
 include/MQMessageConst.h                           |   8 +-
 include/MQMessageExt.h                             | 144 ++--
 include/MQMessageListener.h                        |  30 +-
 include/MQMessageQueue.h                           |  43 +-
 include/MQProducer.h                               |  64 +-
 include/MQPullConsumer.h                           | 103 ---
 include/MQPushConsumer.h                           |  29 +-
 include/MQSelector.h                               |   8 +-
 include/Message.h                                  |  94 +++
 include/MessageExt.h                               |  88 ++
 include/MessageSelector.h                          |  58 ++
 include/MessageUtil.h                              |  18 +-
 .../ResetOffsetBody.h => include/OffsetStore.h     |  35 +-
 include/PullCallback.h                             |  18 +-
 include/QueryResult.h                              |  20 +-
 include/RPCHook.h                                  |  10 +-
 include/RemotingCommand.h                          | 112 +--
 include/RequestCallback.h                          |  22 +-
 include/RocketMQClient.h                           |  12 +-
 include/SendCallback.h                             |  20 +-
 include/SendResult.h                               |  73 +-
 include/SessionCredentials.h                       |  56 +-
 include/TopicFilterType.h                          |   7 +-
 .../TopicMessageQueueChangeListener.h              |  19 +-
 include/TransactionListener.h                      |   9 +-
 include/TransactionMQProducer.h                    |  27 +-
 include/TransactionMQProducerConfig.h              |   9 +-
 include/TransactionSendResult.h                    |  16 +-
 include/c/CBatchMessage.h                          |   6 +-
 include/c/CCommon.h                                |   6 +-
 include/c/CErrorMessage.h                          |   6 +-
 include/c/CMQException.h                           |   6 +-
 include/c/CMessage.h                               |   8 +-
 include/c/CMessageExt.h                            |   8 +-
 include/c/CMessageQueue.h                          |   6 +-
 include/c/CProducer.h                              |   9 +-
 include/c/CPullConsumer.h                          |   6 +-
 include/c/CPullResult.h                            |   7 +-
 include/c/CPushConsumer.h                          |   8 +-
 include/c/CSendResult.h                            |   6 +-
 include/c/CTransactionStatus.h                     |   6 +-
 src/ClientRemotingProcessor.cpp                    |  92 +--
 src/ClientRemotingProcessor.h                      |   8 +-
 src/MQAdminImpl.cpp                                |  44 +-
 src/MQAdminImpl.h                                  |  12 +-
 src/MQClientAPIImpl.cpp                            | 248 +++---
 src/MQClientAPIImpl.h                              |  43 +-
 src/MQClientConfigImpl.cpp                         | 116 ---
 src/MQClientConfigImpl.h                           |  70 --
 src/MQClientConfigImpl.hpp                         | 111 +++
 src/MQClientImpl.cpp                               |  40 +-
 src/MQClientImpl.h                                 |  24 +-
 src/MQClientInstance.cpp                           | 391 +++++----
 src/MQClientInstance.h                             |  68 +-
 src/MQClientManager.cpp                            |  16 +-
 src/MQClientManager.h                              |  15 +-
 src/common/ByteOrder.h                             | 316 +++-----
 src/common/ClientErrorCode.h                       |   6 +-
 src/common/ClientRPCHook.cpp                       |  35 +-
 src/common/CommunicationMode.h                     |   8 +-
 src/common/DataBlock.cpp                           | 239 ------
 src/common/{FilterAPI.h => FilterAPI.hpp}          |  28 +-
 src/common/InputStream.cpp                         | 114 ---
 src/common/InputStream.h                           | 197 -----
 src/common/InvokeCallback.h                        |   7 +-
 src/common/MQVersion.cpp                           |   4 +-
 src/common/MQVersion.h                             | 443 +++-------
 src/common/MemoryInputStream.cpp                   |  82 --
 src/common/MemoryInputStream.h                     |  98 ---
 src/common/MemoryOutputStream.cpp                  | 173 ----
 src/common/MemoryOutputStream.h                    | 132 ---
 src/common/MessageSysFlag.cpp                      |  21 +-
 src/common/MessageSysFlag.h                        |  27 +-
 src/common/NameSpaceUtil.cpp                       |  40 -
 src/common/NameSpaceUtil.h                         |  36 -
 src/common/NamespaceUtil.cpp                       | 119 +++
 src/common/{NamesrvConfig.h => NamespaceUtil.h}    |  30 +-
 src/common/OutputStream.cpp                        | 107 ---
 src/common/OutputStream.h                          | 150 ----
 src/common/PermName.h                              |   9 +-
 src/common/PullCallbackWrap.cpp                    |  20 +-
 src/common/PullCallbackWrap.h                      |  10 +-
 src/common/PullSysFlag.cpp                         |  21 +-
 src/common/PullSysFlag.h                           |  15 +-
 src/common/SendCallbackWrap.cpp                    | 107 ++-
 src/common/SendCallbackWrap.h                      |  44 +-
 src/common/ServiceState.h                          |   6 +-
 src/common/ServiceThread.cpp                       |  36 +-
 src/common/ServiceThread.h                         |  25 +-
 src/common/SubscriptionData.h                      |  73 --
 src/common/SubscriptionGroupConfig.h               |   8 +-
 src/common/TopicConfig.cpp                         |  93 +--
 src/common/TopicConfig.h                           |  50 +-
 src/common/UtilAll.cpp                             | 131 +--
 src/common/UtilAll.h                               |  41 +-
 src/common/Validators.cpp                          |  25 +-
 src/common/Validators.h                            |  18 +-
 src/common/VirtualEnvUtil.cpp                      |   4 +-
 src/common/VirtualEnvUtil.h                        |   9 +-
 src/common/big_endian.cpp                          |  96 ---
 src/common/big_endian.h                            | 101 ---
 src/common/noncopyable.h                           |   6 +-
 src/concurrent/blocking_queue.hpp                  |  94 +++
 src/concurrent/concurrent_queue.hpp                |  36 +-
 src/concurrent/executor.hpp                        |  16 +-
 src/concurrent/executor_impl.hpp                   |  36 +-
 src/concurrent/latch.hpp                           |   6 +-
 src/concurrent/thread.hpp                          |   6 +-
 src/concurrent/thread_group.hpp                    |  14 +-
 src/concurrent/time.hpp                            |   6 +-
 ...locateMQAveragely.h => AllocateMQAveragely.hpp} |   8 +-
 src/consumer/AssignedMessageQueue.hpp              | 219 +++++
 src/consumer/ConsumeMessageConcurrentlyService.cpp |  59 +-
 src/consumer/ConsumeMessageOrderlyService.cpp      |  81 +-
 src/consumer/ConsumeMsgService.h                   |  37 +-
 src/consumer/DefaultLitePullConsumer.cpp           | 130 +++
 src/consumer/DefaultLitePullConsumerConfigImpl.hpp | 150 ++++
 src/consumer/DefaultLitePullConsumerImpl.cpp       | 894 +++++++++++++++++++++
 src/consumer/DefaultLitePullConsumerImpl.h         | 228 ++++++
 src/consumer/DefaultMQPullConsumer.cpp             | 110 ---
 src/consumer/DefaultMQPullConsumerImpl.cpp         | 375 ---------
 src/consumer/DefaultMQPullConsumerImpl.h           | 173 ----
 src/consumer/DefaultMQPushConsumer.cpp             |  51 +-
 src/consumer/DefaultMQPushConsumerConfigImpl.cpp   | 125 ---
 src/consumer/DefaultMQPushConsumerConfigImpl.h     |  81 --
 src/consumer/DefaultMQPushConsumerConfigImpl.hpp   | 110 +++
 src/consumer/DefaultMQPushConsumerImpl.cpp         | 659 ++++++++-------
 src/consumer/DefaultMQPushConsumerImpl.h           | 116 +--
 .../MessageQueue.h => consumer/ExpressionType.cpp} |  16 +-
 .../{FindBrokerResult.h => FindBrokerResult.hpp}   |  25 +-
 src/consumer/LocalFileOffsetStore.cpp              | 193 +++++
 src/consumer/LocalFileOffsetStore.h                |  57 ++
 src/consumer/MQConsumerInner.h                     |  19 +-
 .../consumer/MessageQueueListener.h                |  14 +-
 src/consumer/MessageQueueLock.hpp                  |  18 +-
 src/consumer/OffsetStore.cpp                       | 328 --------
 src/consumer/OffsetStore.h                         | 103 ---
 src/consumer/ProcessQueue.cpp                      | 202 ++---
 src/consumer/ProcessQueue.h                        |  88 +-
 src/consumer/PullAPIWrapper.cpp                    | 117 +--
 src/consumer/PullAPIWrapper.h                      |  45 +-
 src/consumer/PullMessageService.hpp                |  28 +-
 src/consumer/PullRequest.cpp                       |  49 +-
 src/consumer/PullRequest.h                         |  51 +-
 src/consumer/PullResult.cpp                        |  48 +-
 {include => src/consumer}/PullResult.h             |  54 +-
 .../{PullResultExt.h => PullResultExt.hpp}         |  23 +-
 src/consumer/RebalanceImpl.cpp                     | 279 ++++---
 src/consumer/RebalanceImpl.h                       |  50 +-
 src/consumer/RebalanceLitePullImpl.cpp             | 119 +++
 ...RebalancePullImpl.h => RebalanceLitePullImpl.h} |  16 +-
 src/consumer/RebalancePullImpl.cpp                 |  48 --
 src/consumer/RebalancePushImpl.cpp                 |  53 +-
 src/consumer/RebalancePushImpl.h                   |  10 +-
 src/consumer/RebalanceService.h                    |  12 +-
 src/consumer/RemoteBrokerOffsetStore.cpp           | 197 +++++
 src/consumer/RemoteBrokerOffsetStore.h             |  54 ++
 src/consumer/SubscriptionData.cpp                  | 119 ---
 src/extern/CBatchMessage.cpp                       |   9 +-
 ...lientErrorContainer.cpp => CErrorContainer.cpp} |  18 +-
 .../CErrorContainer.h}                             |  17 +-
 src/extern/CErrorMessage.cpp                       |   4 +-
 src/extern/CMessage.cpp                            |  25 +-
 src/extern/CMessageExt.cpp                         |  28 +-
 src/extern/CProducer.cpp                           | 154 ++--
 src/extern/CPullConsumer.cpp                       | 504 ++++++------
 src/extern/CPushConsumer.cpp                       |  82 +-
 src/io/Buffer.hpp                                  | 193 +++++
 src/io/ByteArray.cpp                               |  82 ++
 .../ByteBuffer.cpp}                                |  23 +-
 src/io/ByteBuffer.hpp                              | 184 +++++
 src/io/DefaultByteBuffer.hpp                       | 221 +++++
 src/log/Logging.cpp                                | 136 ++--
 src/log/Logging.h                                  |  94 ++-
 src/message/MQDecoder.cpp                          | 326 --------
 src/message/MQDecoder.h                            |  65 --
 src/message/MQMessage.cpp                          | 210 ++---
 src/message/MQMessageConst.cpp                     |  60 ++
 src/message/MQMessageExt.cpp                       | 184 ++---
 src/message/MQMessageId.h                          |  55 --
 src/message/MQMessageQueue.cpp                     |  78 +-
 .../{MessageAccessor.h => MessageAccessor.hpp}     |  24 +-
 src/message/MessageBatch.cpp                       |  39 +-
 src/message/MessageBatch.h                         |  26 +-
 src/message/MessageClientIDSetter.cpp              |  22 +-
 src/message/MessageClientIDSetter.h                |  33 +-
 src/message/MessageDecoder.cpp                     | 311 +++++++
 src/message/MessageDecoder.h                       |  49 ++
 src/message/MessageExtImpl.cpp                     | 214 +++++
 src/message/MessageExtImpl.h                       | 117 +++
 src/message/MessageId.h                            |  58 ++
 src/message/MessageImpl.cpp                        | 182 +++++
 src/message/MessageImpl.h                          |  90 +++
 src/message/MessageUtil.cpp                        |  52 +-
 src/producer/CorrelationIdUtil.hpp                 |   6 +-
 src/producer/DefaultMQProducer.cpp                 | 135 ++--
 src/producer/DefaultMQProducerConfigImpl.cpp       |  88 --
 src/producer/DefaultMQProducerConfigImpl.h         |  63 --
 src/producer/DefaultMQProducerConfigImpl.hpp       |  84 ++
 src/producer/DefaultMQProducerImpl.cpp             | 697 +++++++++-------
 src/producer/DefaultMQProducerImpl.h               | 124 +--
 src/producer/LatencyFaultTolerancyImpl.cpp         |  64 +-
 src/producer/LatencyFaultTolerancyImpl.h           |  52 +-
 src/producer/MQFaultStrategy.cpp                   |  10 +-
 src/producer/MQFaultStrategy.h                     |   8 +-
 src/producer/MQProducerInner.h                     |   8 +-
 src/producer/RequestFutureTable.cpp                |  16 +-
 src/producer/RequestFutureTable.h                  |  10 +-
 src/producer/RequestResponseFuture.cpp             |  70 +-
 src/producer/RequestResponseFuture.h               |  41 +-
 src/producer/SendResult.cpp                        |  69 +-
 src/producer/TopicPublishInfo.h                    | 111 ---
 src/producer/TopicPublishInfo.hpp                  | 111 +++
 src/producer/TransactionMQProducer.cpp             |  34 +-
 ...gImpl.h => TransactionMQProducerConfigImpl.hpp} |  18 +-
 src/protocol/HeartbeatData.h                       | 109 ---
 src/protocol/MQProtos.h                            |   6 +-
 src/protocol/MessageQueue.cpp                      |  29 -
 .../MessageQueue.hpp}                              |  21 +-
 src/protocol/RemotingCommand.cpp                   | 220 +++--
 src/protocol/RemotingSerializable.cpp              |   8 +-
 src/protocol/RemotingSerializable.h                |  10 +-
 src/protocol/RequestCode.h                         |   8 +-
 src/protocol/ResponseCode.h                        |   6 +-
 src/protocol/TopicList.h                           |  16 +-
 src/protocol/TopicRouteData.h                      | 149 ----
 src/protocol/{ => body}/ConsumerRunningInfo.cpp    |  61 +-
 src/protocol/{ => body}/ConsumerRunningInfo.h      |  63 +-
 src/protocol/body/LockBatchBody.cpp                | 116 ---
 src/protocol/body/LockBatchBody.h                  |  81 --
 src/protocol/body/LockBatchRequestBody.hpp         |  61 ++
 src/protocol/body/LockBatchResponseBody.hpp        |  57 ++
 .../ProcessQueueInfo.hpp}                          |   6 +-
 src/protocol/body/ResetOffsetBody.cpp              |  45 --
 src/protocol/body/ResetOffsetBody.hpp              |  53 ++
 src/protocol/body/TopicRouteData.hpp               | 189 +++++
 src/protocol/body/UnlockBatchRequestBody.hpp       |  61 ++
 src/protocol/header/CommandHeader.cpp              |   6 +-
 src/protocol/header/CommandHeader.h                |  12 +-
 src/protocol/header/ReplyMessageRequestHeader.cpp  | 175 ----
 src/protocol/header/ReplyMessageRequestHeader.h    |  92 ---
 src/protocol/header/ReplyMessageRequestHeader.hpp  | 132 +++
 src/protocol/heartbeat/ConsumerData.hpp            |  83 ++
 src/protocol/heartbeat/HeartbeatData.hpp           |  66 ++
 .../heartbeat/ProducerData.hpp}                    |  36 +-
 src/protocol/heartbeat/SubscriptionData.hpp        | 114 +++
 src/transport/EventLoop.cpp                        | 119 +--
 src/transport/EventLoop.h                          |  51 +-
 src/transport/RequestProcessor.h                   |   6 +-
 src/transport/ResponseFuture.cpp                   |  82 +-
 src/transport/ResponseFuture.h                     |  38 +-
 src/transport/SocketUtil.cpp                       |  41 +-
 src/transport/SocketUtil.h                         |  11 +-
 src/transport/TcpRemotingClient.cpp                | 248 +++---
 src/transport/TcpRemotingClient.h                  |  55 +-
 src/transport/TcpTransport.cpp                     |  80 +-
 src/transport/TcpTransport.h                       |  30 +-
 test/src/common/BigEndianTest.cpp                  |  85 --
 test/src/common/ClientRPCHookTest.cpp              |   8 +-
 test/src/common/MemoryBlockTest.cpp                | 150 ----
 test/src/common/MemoryOutputStreamTest.cpp         | 197 -----
 test/src/common/NamesrvConfigTest.cpp              |  47 --
 test/src/common/TopicConfigTest.cpp                |  50 +-
 test/src/common/ValidatorsTest.cpp                 |   8 +-
 test/src/extern/CMessageExtTest.cpp                |  56 +-
 test/src/extern/CMessageTest.cpp                   |  16 +-
 test/src/extern/CProducerTest.cpp                  |  22 +-
 ...lConsumerTest.cpp => CPullConsumerTest.cpp.bak} |  21 +-
 test/src/extern/CPushConsumerTest.cpp              |  10 +-
 test/src/message/MQDecoderTest.cpp                 | 206 -----
 test/src/message/MQMessageExtTest.cpp              | 120 +--
 test/src/message/MQMessageQueueTest.cpp            |  44 +-
 test/src/message/MQMessageTest.cpp                 | 128 ++-
 test/src/message/MessageBatchTest.cpp              |  25 +-
 test/src/message/MessageDecoderTest.cpp            | 215 +++++
 .../{MQMessageIdTest.cpp => MessageIdTest.cpp}     |   6 +-
 test/src/protocol/CommandHeaderTest.cpp            |  11 +-
 test/src/protocol/ConsumerRunningInfoTest.cpp      |   3 -
 test/src/protocol/HeartbeatDataTest.cpp            |  51 +-
 test/src/protocol/LockBatchBodyTest.cpp            |  28 +-
 test/src/protocol/MessageQueueTest.cpp             |   8 +-
 test/src/protocol/RemotingCommandTest.cpp          | 117 ++-
 test/src/protocol/TopicRouteDataTest.cpp           |  31 +-
 test/src/transport/ClientRemotingProcessorTest.cpp |   8 +-
 test/src/transport/ResponseFutureTest.cpp          |  14 +-
 test/src/transport/SocketUtilTest.cpp              |   5 +-
 329 files changed, 12323 insertions(+), 12220 deletions(-)
 rename example/{PullConsumeMessage.c => PullConsumeMessage.c.bak} (100%)
 rename example/{PullConsumer.cpp => PullConsumer.cpp.bak} (87%)
 create mode 100644 include/Array.h
 copy src/protocol/KVTable.h => include/ByteArray.h (60%)
 delete mode 100644 include/DataBlock.h
 create mode 100755 include/DefaultLitePullConsumer.h
 create mode 100644 include/DefaultLitePullConsumerConfig.h
 create mode 100644 include/DefaultLitePullConsumerConfigProxy.h
 delete mode 100755 include/DefaultMQPullConsumer.h
 delete mode 100644 include/DefaultMQPullConsumerConfig.h
 delete mode 100644 include/DefaultMQPullConsumerConfigProxy.h
 rename src/extern/MQClientErrorContainer.h => include/ExpressionType.h (71%)
 create mode 100644 include/LitePullConsumer.h
 delete mode 100755 include/MQConsumer.h
 rename include/{MQClientException.h => MQException.h} (79%)
 delete mode 100644 include/MQPullConsumer.h
 create mode 100644 include/Message.h
 create mode 100644 include/MessageExt.h
 create mode 100644 include/MessageSelector.h
 copy src/protocol/body/ResetOffsetBody.h => include/OffsetStore.h (52%)
 rename src/protocol/body/ResetOffsetBody.h => include/TopicMessageQueueChangeListener.h
(68%)
 delete mode 100644 src/MQClientConfigImpl.cpp
 delete mode 100644 src/MQClientConfigImpl.h
 create mode 100644 src/MQClientConfigImpl.hpp
 delete mode 100644 src/common/DataBlock.cpp
 rename src/common/{FilterAPI.h => FilterAPI.hpp} (62%)
 delete mode 100644 src/common/InputStream.cpp
 delete mode 100644 src/common/InputStream.h
 delete mode 100644 src/common/MemoryInputStream.cpp
 delete mode 100644 src/common/MemoryInputStream.h
 delete mode 100644 src/common/MemoryOutputStream.cpp
 delete mode 100644 src/common/MemoryOutputStream.h
 delete mode 100644 src/common/NameSpaceUtil.cpp
 delete mode 100644 src/common/NameSpaceUtil.h
 create mode 100644 src/common/NamespaceUtil.cpp
 copy src/common/{NamesrvConfig.h => NamespaceUtil.h} (54%)
 delete mode 100644 src/common/OutputStream.cpp
 delete mode 100644 src/common/OutputStream.h
 mode change 100755 => 100644 src/common/PullCallbackWrap.cpp
 mode change 100755 => 100644 src/common/PullCallbackWrap.h
 mode change 100755 => 100644 src/common/SendCallbackWrap.cpp
 mode change 100755 => 100644 src/common/SendCallbackWrap.h
 delete mode 100644 src/common/SubscriptionData.h
 delete mode 100644 src/common/big_endian.cpp
 delete mode 100644 src/common/big_endian.h
 create mode 100644 src/concurrent/blocking_queue.hpp
 rename src/consumer/{AllocateMQAveragely.h => AllocateMQAveragely.hpp} (93%)
 create mode 100644 src/consumer/AssignedMessageQueue.hpp
 create mode 100644 src/consumer/DefaultLitePullConsumer.cpp
 create mode 100644 src/consumer/DefaultLitePullConsumerConfigImpl.hpp
 create mode 100644 src/consumer/DefaultLitePullConsumerImpl.cpp
 create mode 100755 src/consumer/DefaultLitePullConsumerImpl.h
 delete mode 100644 src/consumer/DefaultMQPullConsumer.cpp
 delete mode 100644 src/consumer/DefaultMQPullConsumerImpl.cpp
 delete mode 100755 src/consumer/DefaultMQPullConsumerImpl.h
 delete mode 100644 src/consumer/DefaultMQPushConsumerConfigImpl.cpp
 delete mode 100644 src/consumer/DefaultMQPushConsumerConfigImpl.h
 create mode 100644 src/consumer/DefaultMQPushConsumerConfigImpl.hpp
 rename src/{protocol/MessageQueue.h => consumer/ExpressionType.cpp} (79%)
 copy src/consumer/{FindBrokerResult.h => FindBrokerResult.hpp} (61%)
 create mode 100644 src/consumer/LocalFileOffsetStore.cpp
 create mode 100644 src/consumer/LocalFileOffsetStore.h
 rename include/MQueueListener.h => src/consumer/MessageQueueListener.h (80%)
 delete mode 100644 src/consumer/OffsetStore.cpp
 delete mode 100644 src/consumer/OffsetStore.h
 rename {include => src/consumer}/PullResult.h (55%)
 rename src/consumer/{PullResultExt.h => PullResultExt.hpp} (74%)
 create mode 100644 src/consumer/RebalanceLitePullImpl.cpp
 rename src/consumer/{RebalancePullImpl.h => RebalanceLitePullImpl.h} (79%)
 delete mode 100644 src/consumer/RebalancePullImpl.cpp
 create mode 100644 src/consumer/RemoteBrokerOffsetStore.cpp
 create mode 100644 src/consumer/RemoteBrokerOffsetStore.h
 delete mode 100644 src/consumer/SubscriptionData.cpp
 copy src/extern/{MQClientErrorContainer.cpp => CErrorContainer.cpp} (68%)
 rename src/{consumer/FindBrokerResult.h => extern/CErrorContainer.h} (71%)
 create mode 100644 src/io/Buffer.hpp
 create mode 100644 src/io/ByteArray.cpp
 rename src/{producer/TransactionMQProducerConfigImpl.cpp => io/ByteBuffer.cpp} (62%)
 create mode 100644 src/io/ByteBuffer.hpp
 create mode 100644 src/io/DefaultByteBuffer.hpp
 delete mode 100644 src/message/MQDecoder.cpp
 delete mode 100644 src/message/MQDecoder.h
 create mode 100644 src/message/MQMessageConst.cpp
 delete mode 100644 src/message/MQMessageId.h
 rename src/message/{MessageAccessor.h => MessageAccessor.hpp} (60%)
 create mode 100644 src/message/MessageDecoder.cpp
 create mode 100644 src/message/MessageDecoder.h
 create mode 100644 src/message/MessageExtImpl.cpp
 create mode 100644 src/message/MessageExtImpl.h
 create mode 100644 src/message/MessageId.h
 create mode 100644 src/message/MessageImpl.cpp
 create mode 100644 src/message/MessageImpl.h
 delete mode 100644 src/producer/DefaultMQProducerConfigImpl.cpp
 delete mode 100644 src/producer/DefaultMQProducerConfigImpl.h
 create mode 100644 src/producer/DefaultMQProducerConfigImpl.hpp
 delete mode 100644 src/producer/TopicPublishInfo.h
 create mode 100644 src/producer/TopicPublishInfo.hpp
 rename src/producer/{TransactionMQProducerConfigImpl.h => TransactionMQProducerConfigImpl.hpp}
(69%)
 delete mode 100644 src/protocol/HeartbeatData.h
 delete mode 100644 src/protocol/MessageQueue.cpp
 rename src/{extern/MQClientErrorContainer.cpp => protocol/MessageQueue.hpp} (69%)
 delete mode 100644 src/protocol/TopicRouteData.h
 rename src/protocol/{ => body}/ConsumerRunningInfo.cpp (56%)
 rename src/protocol/{ => body}/ConsumerRunningInfo.h (51%)
 delete mode 100644 src/protocol/body/LockBatchBody.cpp
 delete mode 100644 src/protocol/body/LockBatchBody.h
 create mode 100644 src/protocol/body/LockBatchRequestBody.hpp
 create mode 100644 src/protocol/body/LockBatchResponseBody.hpp
 rename src/protocol/{ProcessQueueInfo.h => body/ProcessQueueInfo.hpp} (94%)
 delete mode 100644 src/protocol/body/ResetOffsetBody.cpp
 create mode 100644 src/protocol/body/ResetOffsetBody.hpp
 create mode 100644 src/protocol/body/TopicRouteData.hpp
 create mode 100644 src/protocol/body/UnlockBatchRequestBody.hpp
 delete mode 100644 src/protocol/header/ReplyMessageRequestHeader.cpp
 delete mode 100644 src/protocol/header/ReplyMessageRequestHeader.h
 create mode 100644 src/protocol/header/ReplyMessageRequestHeader.hpp
 create mode 100644 src/protocol/heartbeat/ConsumerData.hpp
 create mode 100644 src/protocol/heartbeat/HeartbeatData.hpp
 rename src/{common/NamesrvConfig.h => protocol/heartbeat/ProducerData.hpp} (55%)
 create mode 100644 src/protocol/heartbeat/SubscriptionData.hpp
 delete mode 100644 test/src/common/BigEndianTest.cpp
 delete mode 100644 test/src/common/MemoryBlockTest.cpp
 delete mode 100644 test/src/common/MemoryOutputStreamTest.cpp
 delete mode 100644 test/src/common/NamesrvConfigTest.cpp
 rename test/src/extern/{CPullConsumerTest.cpp => CPullConsumerTest.cpp.bak} (93%)
 delete mode 100644 test/src/message/MQDecoderTest.cpp
 create mode 100644 test/src/message/MessageDecoderTest.cpp
 rename test/src/message/{MQMessageIdTest.cpp => MessageIdTest.cpp} (92%)


Mime
View raw message