You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2021/10/18 07:58:16 UTC
[rocketmq-client-cpp] branch main updated: Format code (#369)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git
The following commit(s) were added to refs/heads/main by this push:
new 5ba187a Format code (#369)
5ba187a is described below
commit 5ba187ac92965afec98efe474814fd837dcfb1c6
Author: aaron ai <ya...@gmail.com>
AuthorDate: Mon Oct 18 15:58:12 2021 +0800
Format code (#369)
---
example/rocketmq/BenchmarkPushConsumer.cpp | 2 +-
example/rocketmq/ExampleAsyncProducer.cpp | 2 +-
example/rocketmq/ExampleBroadcastPushConsumer.cpp | 2 +-
example/rocketmq/ExampleProducer.cpp | 2 +-
example/rocketmq/ExamplePullConsumer.cpp | 2 +-
example/rocketmq/ExamplePushConsumer.cpp | 2 +-
example/rocketmq/ExampleTransactionProducer.cpp | 2 +-
example/rocketmq/PushConsumerWithCustomExecutor.cpp | 4 ++--
example/rocketmq/PushConsumerWithThrottle.cpp | 4 ++--
example/rocketmq/SqlConsumer.cpp | 2 +-
example/rocketmq/SqlProducer.cpp | 2 +-
11 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/example/rocketmq/BenchmarkPushConsumer.cpp b/example/rocketmq/BenchmarkPushConsumer.cpp
index 5d4d3a4..400fa80 100644
--- a/example/rocketmq/BenchmarkPushConsumer.cpp
+++ b/example/rocketmq/BenchmarkPushConsumer.cpp
@@ -22,7 +22,7 @@
#include <mutex>
#include <thread>
- using namespace rocketmq;
+using namespace rocketmq;
class CounterMessageListener : public StandardMessageListener {
public:
diff --git a/example/rocketmq/ExampleAsyncProducer.cpp b/example/rocketmq/ExampleAsyncProducer.cpp
index b4d4bd4..083cb34 100644
--- a/example/rocketmq/ExampleAsyncProducer.cpp
+++ b/example/rocketmq/ExampleAsyncProducer.cpp
@@ -25,7 +25,7 @@
#include <random>
#include <system_error>
- using namespace rocketmq;
+using namespace rocketmq;
int getAndReset(std::atomic_int& counter) {
int current;
diff --git a/example/rocketmq/ExampleBroadcastPushConsumer.cpp b/example/rocketmq/ExampleBroadcastPushConsumer.cpp
index 4302608..529f1e6 100644
--- a/example/rocketmq/ExampleBroadcastPushConsumer.cpp
+++ b/example/rocketmq/ExampleBroadcastPushConsumer.cpp
@@ -24,7 +24,7 @@
#include <mutex>
#include <thread>
- using namespace rocketmq;
+using namespace rocketmq;
class SampleMQMessageListener : public StandardMessageListener {
public:
diff --git a/example/rocketmq/ExampleProducer.cpp b/example/rocketmq/ExampleProducer.cpp
index a74ea9f..e3e2c80 100644
--- a/example/rocketmq/ExampleProducer.cpp
+++ b/example/rocketmq/ExampleProducer.cpp
@@ -20,7 +20,7 @@
#include <iostream>
#include <random>
- using namespace rocketmq;
+using namespace rocketmq;
const std::string& alphaNumeric() {
static std::string alpha_numeric("0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ");
diff --git a/example/rocketmq/ExamplePullConsumer.cpp b/example/rocketmq/ExamplePullConsumer.cpp
index 694956c..7299633 100644
--- a/example/rocketmq/ExamplePullConsumer.cpp
+++ b/example/rocketmq/ExamplePullConsumer.cpp
@@ -21,7 +21,7 @@
#include "rocketmq/DefaultMQPullConsumer.h"
#include "rocketmq/Logger.h"
- int main(int argc, char* argv[]) {
+int main(int argc, char* argv[]) {
const char* group = "GID_group003";
const char* topic = "yc001";
const char* resource_namespace = "MQ_INST_1973281269661160_BXmPlOA6";
diff --git a/example/rocketmq/ExamplePushConsumer.cpp b/example/rocketmq/ExamplePushConsumer.cpp
index 6114a72..8a2e9a6 100644
--- a/example/rocketmq/ExamplePushConsumer.cpp
+++ b/example/rocketmq/ExamplePushConsumer.cpp
@@ -25,7 +25,7 @@
#include "rocketmq/DefaultMQPushConsumer.h"
- using namespace rocketmq;
+using namespace rocketmq;
class SampleMQMessageListener : public StandardMessageListener {
public:
diff --git a/example/rocketmq/ExampleTransactionProducer.cpp b/example/rocketmq/ExampleTransactionProducer.cpp
index 3858174..1fe5b87 100644
--- a/example/rocketmq/ExampleTransactionProducer.cpp
+++ b/example/rocketmq/ExampleTransactionProducer.cpp
@@ -17,7 +17,7 @@
#include "rocketmq/DefaultMQProducer.h"
#include <cstdlib>
- using namespace ROCKETMQ_NAMESPACE;
+using namespace ROCKETMQ_NAMESPACE;
int main(int argc, char* argv[]) {
DefaultMQProducer producer("TestGroup");
diff --git a/example/rocketmq/PushConsumerWithCustomExecutor.cpp b/example/rocketmq/PushConsumerWithCustomExecutor.cpp
index 72212f1..82dd57d 100644
--- a/example/rocketmq/PushConsumerWithCustomExecutor.cpp
+++ b/example/rocketmq/PushConsumerWithCustomExecutor.cpp
@@ -23,9 +23,9 @@
#include <mutex>
#include <thread>
- ROCKETMQ_NAMESPACE_BEGIN
+ROCKETMQ_NAMESPACE_BEGIN
- class ExecutorImpl {
+class ExecutorImpl {
public:
ExecutorImpl() : state_(State::CREATED) {
}
diff --git a/example/rocketmq/PushConsumerWithThrottle.cpp b/example/rocketmq/PushConsumerWithThrottle.cpp
index 29cbd9a..c03b6c5 100644
--- a/example/rocketmq/PushConsumerWithThrottle.cpp
+++ b/example/rocketmq/PushConsumerWithThrottle.cpp
@@ -22,9 +22,9 @@
#include <mutex>
#include <thread>
- ROCKETMQ_NAMESPACE_BEGIN
+ROCKETMQ_NAMESPACE_BEGIN
- class CounterMessageListener : public StandardMessageListener {
+class CounterMessageListener : public StandardMessageListener {
public:
explicit CounterMessageListener(std::atomic_long& counter) : counter_(counter) {
}
diff --git a/example/rocketmq/SqlConsumer.cpp b/example/rocketmq/SqlConsumer.cpp
index 11c16ef..c07e4a0 100644
--- a/example/rocketmq/SqlConsumer.cpp
+++ b/example/rocketmq/SqlConsumer.cpp
@@ -21,7 +21,7 @@
#include <mutex>
#include <thread>
- using namespace rocketmq;
+using namespace rocketmq;
class SampleMQMessageListener : public StandardMessageListener {
public:
diff --git a/example/rocketmq/SqlProducer.cpp b/example/rocketmq/SqlProducer.cpp
index 20900f9..bc0fb47 100644
--- a/example/rocketmq/SqlProducer.cpp
+++ b/example/rocketmq/SqlProducer.cpp
@@ -17,7 +17,7 @@
#include "rocketmq/DefaultMQProducer.h"
#include <iostream>
- using namespace rocketmq;
+using namespace rocketmq;
int main(int argc, char* argv[]) {