[rocketmq-client-cpp] branch master updated: style(formatting, missing semicolons, …)

[vongosling]

This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/master by this push:
     new babe3ed  style(formatting, missing semicolons, …)
babe3ed is described below

commit babe3ed04e09bda634ef76efa2d2b1af22dd26ca
Author: vongosling <vongosl...@apache.org>
AuthorDate: Fri Jan 3 16:25:16 2020 +0800

    style(formatting, missing semicolons, …)
---
 include/DefaultMQPullConsumer.h | 11 +++--------
 include/DefaultMQPushConsumer.h |  4 ++--
 2 files changed, 5 insertions(+), 10 deletions(-)

diff --git a/include/DefaultMQPullConsumer.h b/include/DefaultMQPullConsumer.h
index 899862b..8e1612d 100644
--- a/include/DefaultMQPullConsumer.h
+++ b/include/DefaultMQPullConsumer.h
@@ -60,7 +60,7 @@ class ROCKETMQCLIENT_API DefaultMQPullConsumer : public 
MQConsumer {
 
   void registerMessageQueueListener(const std::string& topic, MQueueListener* 
pListener);
   /**
-   * pull msg from specified queue, if no msg in queue, return directly
+   * Pull message from specified queue, if no msg in queue, return directly
    *
    * @param mq
    *            specify the pulled queue
@@ -73,7 +73,7 @@ class ROCKETMQCLIENT_API DefaultMQPullConsumer : public 
MQConsumer {
    * @param maxNums
    *            specify max msg num by per pull
    * @return
-   *            accroding to PullResult
+   *            PullResult
    */
   virtual PullResult pull(const MQMessageQueue& mq, const std::string& 
subExpression, int64 offset, int maxNums);
   virtual void pull(const MQMessageQueue& mq,
@@ -106,12 +106,7 @@ class ROCKETMQCLIENT_API DefaultMQPullConsumer : public 
MQConsumer {
                            PullCallback* pPullCallback);
 
   virtual ConsumerRunningInfo* getConsumerRunningInfo() { return NULL; }
-  /**
-   *
-   * @param mq
-   * @param fromStore
-   * @return
-   */
+
   int64 fetchConsumeOffset(const MQMessageQueue& mq, bool fromStore);
 
   void fetchMessageQueuesInBalance(const std::string& topic, 
std::vector<MQMessageQueue> mqs);
diff --git a/include/DefaultMQPushConsumer.h b/include/DefaultMQPushConsumer.h
index 43f0fbb..2ff7620 100644
--- a/include/DefaultMQPushConsumer.h
+++ b/include/DefaultMQPushConsumer.h
@@ -93,8 +93,8 @@ class ROCKETMQCLIENT_API DefaultMQPushConsumer : public 
MQConsumer {
                                             boost::weak_ptr<PullRequest>);
   void triggerNextPullRequest(boost::asio::deadline_timer* t, 
boost::weak_ptr<PullRequest>);
   void runPullMsgQueue(TaskQueue* pTaskQueue);
-  void pullMessage(boost::weak_ptr<PullRequest> pullrequest);       // sync 
pullMsg
-  void pullMessageAsync(boost::weak_ptr<PullRequest> pullrequest);  // async 
pullMsg
+  void pullMessage(boost::weak_ptr<PullRequest> pullrequest);
+  void pullMessageAsync(boost::weak_ptr<PullRequest> pullrequest);
   void setAsyncPull(bool asyncFlag);
   AsyncPullCallback* getAsyncPullCallBack(boost::weak_ptr<PullRequest>, 
MQMessageQueue msgQueue);
   void shutdownAsyncPullCallBack();