rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From duhengfore...@apache.org
Subject [rocketmq-client-cpp] 01/01: Merge pull request #1 from ShannonDing/master
Date Thu, 25 Oct 2018 07:17:05 GMT
This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git

commit 6e196f59167aad1b478bd17c53f0b8e7d868a928
Merge: ab5624a bea4da9
Author: duheng <39583243+duhengforever@users.noreply.github.com>
AuthorDate: Thu Oct 25 15:16:58 2018 +0800

    Merge pull request #1 from ShannonDing/master
    
    [FEATURE REQUEST #488]Export C-style APIs for RocketMQ client

 CMakeLists.txt                                     |  189 ++
 Makefile                                           |  215 +++
 README.md                                          |  139 +-
 cmake/FindJsoncpp.cmake                            |   96 +
 cmake/FindLibevent.cmake                           |  152 ++
 deploy.sh                                          |   42 +
 doc/rocketmq-cpp_manual_zh.docx                    |  Bin 0 -> 274831 bytes
 example/AsyncProducer.cpp                          |  140 ++
 example/AsyncPushConsumer.cpp                      |  111 ++
 .../AsyncProducer.dir/AsyncProducer.cpp.o          |  Bin 0 -> 1887024 bytes
 example/CMakeLists.txt                             |   41 +
 example/Makefile                                   |  509 +++++
 example/OrderProducer.cpp                          |  114 ++
 example/OrderlyPushConsumer.cpp                    |  111 ++
 example/PullConsumer.cpp                           |  125 ++
 example/PushConsumer.cpp                           |  126 ++
 example/README.md                                  |    4 +
 example/SendDelayMsg.cpp                           |   66 +
 example/SyncProducer.cpp                           |  116 ++
 example/common.h                                   |  220 +++
 format.sh                                          |   77 +
 include/Arg_helper.h                               |   42 +
 include/AsyncCallback.h                            |   66 +
 include/CCommon.h                                  |   38 +
 include/CMessage.h                                 |   41 +
 include/CMessageExt.h                              |   39 +
 include/CMessageQueue.h                            |   35 +
 include/CProducer.h                                |   44 +
 include/CPullConsumer.h                            |   45 +
 include/CPullResult.h                              |   48 +
 include/CPushConsumer.h                            |   53 +
 include/CSendResult.h                              |   42 +
 include/ConsumeType.h                              |   61 +
 include/DefaultMQProducer.h                        |  106 ++
 include/DefaultMQPullConsumer.h                    |  155 ++
 include/DefaultMQPushConsumer.h                    |  160 ++
 include/MQClient.h                                 |  203 ++
 include/MQClientException.h                        |   95 +
 include/MQConsumer.h                               |   70 +
 include/MQMessage.h                                |  105 ++
 include/MQMessageExt.h                             |  117 ++
 include/MQMessageListener.h                        |   90 +
 include/MQMessageQueue.h                           |   64 +
 include/MQProducer.h                               |   62 +
 include/MQSelector.h                               |   33 +
 include/MQueueListener.h                           |   34 +
 include/PullResult.h                               |   69 +
 include/QueryResult.h                              |   43 +
 include/RocketMQClient.h                           |   47 +
 include/SendMessageHook.h                          |   47 +
 include/SendResult.h                               |   58 +
 include/SessionCredentials.h                       |   62 +
 libs/CMakeLists.txt                                |   16 +
 libs/Makefile                                      |  173 ++
 libs/signature/CMakeLists.txt                      |   25 +
 libs/signature/Makefile                            |  377 ++++
 libs/signature/include/base64.h                    |   53 +
 libs/signature/include/hmac.h                      |   71 +
 libs/signature/include/param_list.h                |   56 +
 libs/signature/include/sha1.h                      |   91 +
 libs/signature/include/sha256.h                    |   91 +
 libs/signature/include/sha512.h                    |   95 +
 libs/signature/include/spas_client.h               |  104 ++
 libs/signature/include/u64.h                       |  157 ++
 libs/signature/lib/.gitkeep                        |    1 +
 libs/signature/src/base64.c                        |  409 ++++
 libs/signature/src/hmac.c                          |  181 ++
 libs/signature/src/param_list.c                    |  142 ++
 libs/signature/src/sha1.c                          |  507 +++++
 libs/signature/src/sha256.c                        |  559 ++++++
 libs/signature/src/sha512.c                        |  609 ++++++
 libs/signature/src/spas_client.c                   |  506 +++++
 project/CMakeLists.txt                             |   67 +
 project/Makefile                                   | 1943 ++++++++++++++++++++
 src/MQClientAPIImpl.cpp                            |  929 ++++++++++
 src/MQClientAPIImpl.h                              |  189 ++
 src/MQClientFactory.cpp                            | 1150 ++++++++++++
 src/MQClientFactory.h                              |  220 +++
 src/MQClientManager.cpp                            |   54 +
 src/MQClientManager.h                              |   49 +
 src/common/Arg_helper.cpp                          |   67 +
 src/common/AsyncArg.h                              |   36 +
 src/common/AsyncCallbackWrap.cpp                   |  168 ++
 src/common/AsyncCallbackWrap.h                     |   84 +
 src/common/ByteOrder.h                             |  194 ++
 src/common/ClientRPCHook.cpp                       |   84 +
 src/common/ClientRPCHook.h                         |   51 +
 src/common/CommunicationMode.h                     |   27 +
 src/common/FilterAPI.h                             |   63 +
 src/common/InputStream.cpp                         |  109 ++
 src/common/InputStream.h                           |  195 ++
 src/common/MQClient.cpp                            |  203 ++
 src/common/MQVersion.cpp                           |   31 +
 src/common/MQVersion.h                             |  229 +++
 src/common/MemoryInputStream.cpp                   |   71 +
 src/common/MemoryInputStream.h                     |   97 +
 src/common/MemoryOutputStream.cpp                  |  164 ++
 src/common/MemoryOutputStream.h                    |  132 ++
 src/common/MessageSysFlag.cpp                      |   37 +
 src/common/MessageSysFlag.h                        |   38 +
 src/common/NamesrvConfig.h                         |   56 +
 src/common/OutputStream.cpp                        |  101 +
 src/common/OutputStream.h                          |  149 ++
 src/common/PermName.cpp                            |   55 +
 src/common/PermName.h                              |   39 +
 src/common/PullSysFlag.cpp                         |   70 +
 src/common/PullSysFlag.h                           |   41 +
 src/common/ServiceState.h                          |   25 +
 src/common/SubscriptionGroupConfig.h               |   49 +
 src/common/TopAddressing.cpp                       |  104 ++
 src/common/TopAddressing.h                         |   47 +
 src/common/TopicConfig.cpp                         |  104 ++
 src/common/TopicConfig.h                           |   61 +
 src/common/TopicFilterType.h                       |   34 +
 src/common/UtilAll.cpp                             |  336 ++++
 src/common/UtilAll.h                               |  145 ++
 src/common/Validators.cpp                          |  115 ++
 src/common/Validators.h                            |   43 +
 src/common/VirtualEnvUtil.cpp                      |   56 +
 src/common/VirtualEnvUtil.h                        |   36 +
 src/common/big_endian.cpp                          |   75 +
 src/common/big_endian.h                            |  101 +
 src/common/dataBlock.cpp                           |  189 ++
 src/common/dataBlock.h                             |  205 +++
 src/common/sync_http_client.cpp                    |  156 ++
 src/common/sync_http_client.h                      |   29 +
 src/common/url.cpp                                 |   63 +
 src/common/url.h                                   |   38 +
 src/consumer/AllocateMQStrategy.h                  |  100 +
 src/consumer/ConsumeMessageConcurrentlyService.cpp |  155 ++
 src/consumer/ConsumeMessageOrderlyService.cpp      |  221 +++
 src/consumer/ConsumeMsgService.h                   |  112 ++
 src/consumer/DefaultMQPullConsumer.cpp             |  384 ++++
 src/consumer/DefaultMQPushConsumer.cpp             |  936 ++++++++++
 src/consumer/FindBrokerResult.h                    |   33 +
 src/consumer/OffsetStore.cpp                       |  370 ++++
 src/consumer/OffsetStore.h                         |  108 ++
 src/consumer/PullAPIWrapper.cpp                    |  139 ++
 src/consumer/PullAPIWrapper.h                      |   67 +
 src/consumer/PullRequest.cpp                       |  264 +++
 src/consumer/PullRequest.h                         |   97 +
 src/consumer/PullResult.cpp                        |   54 +
 src/consumer/PullResultExt.h                       |   45 +
 src/consumer/Rebalance.cpp                         |  683 +++++++
 src/consumer/Rebalance.h                           |  123 ++
 src/consumer/SubscriptionData.cpp                  |  120 ++
 src/consumer/SubscriptionData.h                    |   62 +
 src/dllmain.cpp                                    |   34 +
 src/extern/CMessage.cpp                            |   88 +
 src/extern/CMessageExt.cpp                         |   63 +
 src/extern/CProducer.cpp                           |   98 +
 src/extern/CPullConsumer.cpp                       |   82 +
 src/extern/CPushConsumer.cpp                       |  160 ++
 src/extern/CSendResult.cpp                         |   27 +
 src/log/Logging.cpp                                |  114 ++
 src/log/Logging.h                                  |   94 +
 src/message/MQDecoder.cpp                          |  254 +++
 src/message/MQDecoder.h                            |   57 +
 src/message/MQMessage.cpp                          |  197 ++
 src/message/MQMessageExt.cpp                       |  148 ++
 src/message/MQMessageId.h                          |   45 +
 src/message/MQMessageQueue.cpp                     |   98 +
 src/producer/DefaultMQProducer.cpp                 |  496 +++++
 src/producer/SendResult.cpp                        |   60 +
 src/producer/TopicPublishInfo.h                    |  279 +++
 src/protocol/CommandHeader.cpp                     |  592 ++++++
 src/protocol/CommandHeader.h                       |  431 +++++
 src/protocol/ConsumerRunningInfo.cpp               |  125 ++
 src/protocol/ConsumerRunningInfo.h                 |   66 +
 src/protocol/HeartbeatData.h                       |  143 ++
 src/protocol/KVTable.h                             |   41 +
 src/protocol/LockBatchBody.cpp                     |  124 ++
 src/protocol/LockBatchBody.h                       |   80 +
 src/protocol/MQProtos.h                            |  199 ++
 src/protocol/MessageQueue.cpp                      |  108 ++
 src/protocol/MessageQueue.h                        |   56 +
 src/protocol/ProcessQueueInfo.h                    |  103 ++
 src/protocol/RemotingCommand.cpp                   |  253 +++
 src/protocol/RemotingCommand.h                     |   90 +
 src/protocol/RemotingSerializable.h                |   32 +
 src/protocol/TopicList.h                           |   35 +
 src/protocol/TopicRouteData.h                      |  177 ++
 src/thread/disruptor/batch_descriptor.h            |   70 +
 src/thread/disruptor/claim_strategy.h              |  231 +++
 src/thread/disruptor/event_processor.h             |  130 ++
 src/thread/disruptor/event_publisher.h             |   50 +
 src/thread/disruptor/exception_handler.h           |   59 +
 src/thread/disruptor/exceptions.h                  |   38 +
 src/thread/disruptor/interface.h                   |  278 +++
 src/thread/disruptor/ring_buffer.h                 |   90 +
 src/thread/disruptor/sequence.h                    |  139 ++
 src/thread/disruptor/sequence_barrier.h            |   92 +
 src/thread/disruptor/sequencer.h                   |  190 ++
 src/thread/disruptor/utils.h                       |   35 +
 src/thread/disruptor/wait_strategy.h               |  372 ++++
 src/thread/disruptorLFQ.h                          |  123 ++
 src/thread/task_queue.cpp                          |  109 ++
 src/thread/task_queue.h                            |  677 +++++++
 src/transport/ClientRemotingProcessor.cpp          |  162 ++
 src/transport/ClientRemotingProcessor.h            |   55 +
 src/transport/ResponseFuture.cpp                   |  176 ++
 src/transport/ResponseFuture.h                     |   83 +
 src/transport/SocketUtil.cpp                       |   86 +
 src/transport/SocketUtil.h                         |   63 +
 src/transport/TcpRemotingClient.cpp                |  734 ++++++++
 src/transport/TcpRemotingClient.h                  |  133 ++
 src/transport/TcpTransport.cpp                     |  352 ++++
 src/transport/TcpTransport.h                       |   96 +
 208 files changed, 31937 insertions(+), 1 deletion(-)


Mime
View raw message