rocketmq-client-cpp
Apache RocketMQ cpp client
File Explorer
Download Latest Version (.zip)- issue_template.md
- check-git-clang-format.sh
- git-clang-format
- FindJsoncpp.cmake
- FindLibevent.cmake
- control
- postinst
- build.sh
- deploy.sh
- AsyncProducer.cpp
- AsyncPushConsumer.cpp
- BatchProducer.cpp
- CAsyncProducer.c
- CBatchProducer.c
- CMakeLists.txt
- common.h
- COrderlyAsyncProducer.c
- OrderlyPushConsumer.cpp
- OrderProducer.cpp
- Producer.c
- PullConsumeMessage.c
- PullConsumer.cpp
- PushConsumeMessage.c
- PushConsumer.cpp
- PushConsumerOrderly.c
- README.md
- SendDelayMsg.cpp
- SyncProducer.cpp
- TransactionProducer.cpp
- Arg_helper.h
- AsyncCallback.h
- CBatchMessage.h
- CCommon.h
- CErrorMessage.h
- CMessage.h
- CMessageExt.h
- CMessageQueue.h
- CMQException.h
- ConsumeType.h
- CProducer.h
- CPullConsumer.h
- CPullResult.h
- CPushConsumer.h
- CSendResult.h
- CTransactionStatus.h
- DefaultMQProducer.h
- DefaultMQPullConsumer.h
- DefaultMQPushConsumer.h
- MQClient.h
- MQClientException.h
- MQMessage.h
- MQMessageExt.h
- MQMessageListener.h
- MQMessageQueue.h
- MQSelector.h
- MQueueListener.h
- PullResult.h
- RocketMQClient.h
- SendResult.h
- SessionCredentials.h
- TransactionListener.h
- TransactionMQProducer.h
- TransactionSendResult.h
- base64.h
- hmac.h
- param_list.h
- sha1.h
- sha256.h
- sha512.h
- spas_client.h
- u64.h
- base64.c
- hmac.c
- param_list.c
- sha1.c
- sha256.c
- sha512.c
- spas_client.c
- CMakeLists.txt
- CMakeLists.txt
- CMakeLists.txt
- rocketmq-client-cpp.spec
- build.sh
- DefaultMQAdmin.cpp
- DefaultMQAdmin.h
- Arg_helper.cpp
- AsyncArg.h
- AsyncCallbackWrap.cpp
- AsyncCallbackWrap.h
- big_endian.cpp
- big_endian.h
- ByteOrder.h
- ClientRPCHook.cpp
- ClientRPCHook.h
- CommunicationMode.h
- dataBlock.cpp
- dataBlock.h
- DefaultMQClient.cpp
- FilterAPI.h
- InputStream.cpp
- InputStream.h
- MemoryInputStream.cpp
- MemoryInputStream.h
- MemoryOutputStream.cpp
- MemoryOutputStream.h
- MessageAccessor.cpp
- MessageAccessor.h
- MessageSysFlag.cpp
- MessageSysFlag.h
- MQClientErrorContainer.cpp
- MQClientErrorContainer.h
- MQVersion.cpp
- MQVersion.h
- NameSpaceUtil.cpp
- NameSpaceUtil.h
- NamesrvConfig.h
- noncopyable.h
- OutputStream.cpp
- OutputStream.h
- PermName.cpp
- PermName.h
- PullSysFlag.cpp
- PullSysFlag.h
- ServiceState.h
- SubscriptionGroupConfig.h
- sync_http_client.cpp
- sync_http_client.h
- TopAddressing.cpp
- TopAddressing.h
- TopicConfig.cpp
- TopicConfig.h
- TopicFilterType.h
- url.cpp
- url.h
- UtilAll.cpp
- UtilAll.h
- Validators.cpp
- Validators.h
- VirtualEnvUtil.cpp
- VirtualEnvUtil.h
- AllocateMQStrategy.h
- ConsumeMessageConcurrentlyService.cpp
- ConsumeMessageHookImpl.cpp
- ConsumeMessageHookImpl.h
- ConsumeMessageOrderlyService.cpp
- ConsumeMsgService.h
- DefaultMQPullConsumer.cpp
- DefaultMQPullConsumerImpl.cpp
- DefaultMQPullConsumerImpl.h
- DefaultMQPushConsumer.cpp
- DefaultMQPushConsumerImpl.cpp
- DefaultMQPushConsumerImpl.h
- FindBrokerResult.h
- OffsetStore.cpp
- OffsetStore.h
- PullAPIWrapper.cpp
- PullAPIWrapper.h
- PullRequest.cpp
- PullRequest.h
- PullResult.cpp
- PullResultExt.h
- Rebalance.cpp
- Rebalance.h
- SubscriptionData.cpp
- SubscriptionData.h
- CBatchMessage.cpp
- CErrorMessage.cpp
- CMessage.cpp
- CMessageExt.cpp
- CProducer.cpp
- CPullConsumer.cpp
- CPushConsumer.cpp
- CSendResult.cpp
- BatchMessage.h
- DefaultMQClient.h
- MQAdmin.h
- MQConsumer.h
- MQProducer.h
- QueryResult.h
- Logging.cpp
- Logging.h
- BatchMessage.cpp
- MQDecoder.cpp
- MQDecoder.h
- MQMessage.cpp
- MQMessageExt.cpp
- MQMessageId.h
- MQMessageQueue.cpp
- DefaultMQProducer.cpp
- DefaultMQProducerImpl.cpp
- DefaultMQProducerImpl.h
- SendMessageHookImpl.cpp
- SendMessageHookImpl.h
- SendResult.cpp
- StringIdMaker.cpp
- StringIdMaker.h
- TopicPublishInfo.h
- TransactionMQProducer.cpp
- TransactionMQProducerImpl.cpp
- TransactionMQProducerImpl.h
- CommandHeader.cpp
- CommandHeader.h
- ConsumerRunningInfo.cpp
- ConsumerRunningInfo.h
- HeartbeatData.h
- KVTable.h
- LockBatchBody.cpp
- LockBatchBody.h
- MessageQueue.cpp
- MessageQueue.h
- MQProtos.h
- ProcessQueueInfo.h
- RemotingCommand.cpp
- RemotingCommand.h
- RemotingSerializable.h
- TopicList.h
- TopicRouteData.h
- ConsumeStats.cpp
- ConsumeStats.h
- StatsItem.h
- StatsServer.cpp
- StatsServer.h
- StatsServerManager.cpp
- StatsServerManager.h
- batch_descriptor.h
- claim_strategy.h
- event_processor.h
- event_publisher.h
- exception_handler.h
- exceptions.h
- interface.h
- ring_buffer.h
- sequence.h
- sequence_barrier.h
- sequencer.h
- utils.h
- wait_strategy.h
- disruptorLFQ.h
- task_queue.cpp
- task_queue.h
- ConsumeMessageContext.cpp
- ConsumeMessageContext.h
- ConsumeMessageHook.h
- SendMessageContext.cpp
- SendMessageContext.h
- SendMessageHook.h
- TraceBean.cpp
- TraceBean.h
- TraceConstant.cpp
- TraceConstant.h
- TraceContext.cpp
- TraceContext.h
- TraceTransferBean.cpp
- TraceTransferBean.h
- TraceUtil.cpp
- TraceUtil.h
- ClientRemotingProcessor.cpp
- ClientRemotingProcessor.h
- EventLoop.cpp
- EventLoop.h
- ResponseFuture.cpp
- ResponseFuture.h
- SocketUtil.cpp
- SocketUtil.h
- TcpRemotingClient.cpp
- TcpRemotingClient.h
- TcpTransport.cpp
- TcpTransport.h
- dllmain.cpp
- MQClientAPIImpl.cpp
- MQClientAPIImpl.h
- MQClientFactory.cpp
- MQClientFactory.h
- MQClientManager.cpp
- MQClientManager.h
- big_endianTest.cpp
- ClientRPCHookTest.cpp
- MemoryBlockTest.cpp
- MemoryOutputStreamTest.cpp
- MQVersionTest.cpp
- NameSpaceUtilTest.cpp
- NamesrvConfigTest.cpp
- PermNametTest.cpp
- PullSysFlagTest.cpp
- TopicConfigTest.cpp
- UrlTest.cpp
- UtilAllTest.cpp
- ValidatorsTest.cpp
- VirtualEnvUtilTest.cpp
- DefaultMQPushConsumerImplTest.cpp
- CMessageExtTest.cpp
- CMessageTest.cpp
- CProducerTest.cpp
- CPullConsumerTest.cpp
- CPushConsumerTest.cpp
- BatchMessageTest.cpp
- MQDecoderTest.cpp
- MQMessageExtTest.cpp
- MQMessageIdTest.cpp
- MQMessageQueueTest.cpp
- MQMessageTest.cpp
- DefaultMQProducerImplTest.cpp
- StringIdMakerTest.cpp
- TopicPublishInfoTest.cpp
- CommandHeaderTest.cpp
- ConsumerRunningInfoTest.cpp
- HeartbeatDataTest.cpp
- KVTableTest.cpp
- LockBatchBodyTest.cpp
- MessageQueueTest.cpp
- ProcessQueueInfoTest.cpp
- RemotingCommandTest.cpp
- TopicRouteDataTest.cpp
- TraceBeanTest.cpp
- TraceUtilTest.cpp
- ClientRemotingProcessorTest.cpp
- ResponseFutureTest.cpp
- SocketUtilTest.cpp
- MQClientAPIImpTest.cpp
- MQClientFactoryTest.cpp
- MQClientManagerTest.cpp
- CMakeLists.txt
- rocketmq-client-cpp.sln
- rocketmq-client-cpp.vcxproj
- rocketmq-client-cpp.vcxproj.filters
- .asf.yaml
- .clang-format
- .gitignore
- .travis.yml
- build.sh
- CMakeLists.txt
- CONTRIBUTING.md
- format.sh
- LICENSE
- NOTICE
- package_rocketmq.mri
- PULL_REQUEST_TEMPLATE.md
- README.md
- win32_build.bat
// repository documentation
Was this content helpful?
(0 ratings)