You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2020/02/21 14:28:58 UTC
[rocketmq-client-cpp] branch master updated: refactor(warning):
remove warnings in header files (#251)
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 b5794ae refactor(warning): remove warnings in header files (#251)
b5794ae is described below
commit b5794aea38063c1982651126db4e174baa0eb0ab
Author: dinglei <li...@163.com>
AuthorDate: Fri Feb 21 22:28:49 2020 +0800
refactor(warning): remove warnings in header files (#251)
---
include/DefaultMQProducer.h | 6 +++---
include/DefaultMQPushConsumer.h | 6 +++---
include/TransactionMQProducer.h | 6 +++---
src/common/DefaultMQClient.cpp | 6 +++---
src/consumer/DefaultMQPushConsumer.cpp | 6 +++---
src/include/DefaultMQClient.h | 6 +++---
src/producer/DefaultMQProducer.cpp | 6 +++---
src/producer/TransactionMQProducer.cpp | 6 +++---
8 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/include/DefaultMQProducer.h b/include/DefaultMQProducer.h
index 0b938ac..4614244 100644
--- a/include/DefaultMQProducer.h
+++ b/include/DefaultMQProducer.h
@@ -113,7 +113,7 @@ class ROCKETMQCLIENT_API DefaultMQProducer {
* producer and consumer must set different instanceName.
**/
void setTcpTransportPullThreadNum(int num);
- const int getTcpTransportPullThreadNum() const;
+ int getTcpTransportPullThreadNum() const;
/** Timeout of tcp connect, it is same meaning for both producer and consumer;
* 1. default value is 3000ms
@@ -121,7 +121,7 @@ class ROCKETMQCLIENT_API DefaultMQProducer {
* 1000-3000ms;
**/
void setTcpTransportConnectTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportConnectTimeout() const;
+ uint64_t getTcpTransportConnectTimeout() const;
/** Timeout of tryLock tcpTransport before sendMsg/pullMsg, if timeout,
* returns NULL
@@ -131,7 +131,7 @@ class ROCKETMQCLIENT_API DefaultMQProducer {
* will be setted to 1000ms
**/
void setTcpTransportTryLockTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportTryLockTimeout() const;
+ uint64_t getTcpTransportTryLockTimeout() const;
void setUnitName(std::string unitName);
const std::string& getUnitName() const;
diff --git a/include/DefaultMQPushConsumer.h b/include/DefaultMQPushConsumer.h
index 686f6e7..2b8f672 100644
--- a/include/DefaultMQPushConsumer.h
+++ b/include/DefaultMQPushConsumer.h
@@ -107,7 +107,7 @@ class ROCKETMQCLIENT_API DefaultMQPushConsumer {
* producer and consumer must set different instanceName.
**/
void setTcpTransportPullThreadNum(int num);
- const int getTcpTransportPullThreadNum() const;
+ int getTcpTransportPullThreadNum() const;
/** Timeout of tcp connect, it is same meaning for both producer and consumer;
* 1. default value is 3000ms
@@ -115,7 +115,7 @@ class ROCKETMQCLIENT_API DefaultMQPushConsumer {
* 1000-3000ms;
**/
void setTcpTransportConnectTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportConnectTimeout() const;
+ uint64_t getTcpTransportConnectTimeout() const;
/** Timeout of tryLock tcpTransport before sendMsg/pullMsg, if timeout,
* returns NULL
@@ -125,7 +125,7 @@ class ROCKETMQCLIENT_API DefaultMQPushConsumer {
* will be setted to 1000ms
**/
void setTcpTransportTryLockTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportTryLockTimeout() const;
+ uint64_t getTcpTransportTryLockTimeout() const;
void setUnitName(std::string unitName);
const std::string& getUnitName() const;
diff --git a/include/TransactionMQProducer.h b/include/TransactionMQProducer.h
index 2a8a792..9de728a 100644
--- a/include/TransactionMQProducer.h
+++ b/include/TransactionMQProducer.h
@@ -59,13 +59,13 @@ class ROCKETMQCLIENT_API TransactionMQProducer {
int getSendMsgTimeout() const;
void setSendMsgTimeout(int sendMsgTimeout);
void setTcpTransportPullThreadNum(int num);
- const int getTcpTransportPullThreadNum() const;
+ int getTcpTransportPullThreadNum() const;
void setTcpTransportConnectTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportConnectTimeout() const;
+ uint64_t getTcpTransportConnectTimeout() const;
void setTcpTransportTryLockTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportTryLockTimeout() const;
+ uint64_t getTcpTransportTryLockTimeout() const;
int getCompressMsgBodyOverHowmuch() const;
void setCompressMsgBodyOverHowmuch(int compressMsgBodyOverHowmuch);
diff --git a/src/common/DefaultMQClient.cpp b/src/common/DefaultMQClient.cpp
index e0fcd8e..f468b7f 100644
--- a/src/common/DefaultMQClient.cpp
+++ b/src/common/DefaultMQClient.cpp
@@ -183,14 +183,14 @@ void DefaultMQClient::setTcpTransportPullThreadNum(int num) {
}
}
-const int DefaultMQClient::getTcpTransportPullThreadNum() const {
+int DefaultMQClient::getTcpTransportPullThreadNum() const {
return m_pullThreadNum;
}
void DefaultMQClient::setTcpTransportConnectTimeout(uint64_t timeout) {
m_tcpConnectTimeout = timeout;
}
-const uint64_t DefaultMQClient::getTcpTransportConnectTimeout() const {
+uint64_t DefaultMQClient::getTcpTransportConnectTimeout() const {
return m_tcpConnectTimeout;
}
@@ -200,7 +200,7 @@ void DefaultMQClient::setTcpTransportTryLockTimeout(uint64_t timeout) {
}
m_tcpTransportTryLockTimeout = timeout / 1000;
}
-const uint64_t DefaultMQClient::getTcpTransportTryLockTimeout() const {
+uint64_t DefaultMQClient::getTcpTransportTryLockTimeout() const {
return m_tcpTransportTryLockTimeout;
}
diff --git a/src/consumer/DefaultMQPushConsumer.cpp b/src/consumer/DefaultMQPushConsumer.cpp
index b0373c0..dc02d9d 100644
--- a/src/consumer/DefaultMQPushConsumer.cpp
+++ b/src/consumer/DefaultMQPushConsumer.cpp
@@ -176,20 +176,20 @@ const std::string& DefaultMQPushConsumer::getUnitName() const {
void DefaultMQPushConsumer::setTcpTransportPullThreadNum(int num) {
impl->setTcpTransportPullThreadNum(num);
}
-const int DefaultMQPushConsumer::getTcpTransportPullThreadNum() const {
+int DefaultMQPushConsumer::getTcpTransportPullThreadNum() const {
return impl->getTcpTransportPullThreadNum();
}
void DefaultMQPushConsumer::setTcpTransportConnectTimeout(uint64_t timeout) {
impl->setTcpTransportConnectTimeout(timeout);
}
-const uint64_t DefaultMQPushConsumer::getTcpTransportConnectTimeout() const {
+uint64_t DefaultMQPushConsumer::getTcpTransportConnectTimeout() const {
return impl->getTcpTransportConnectTimeout();
}
void DefaultMQPushConsumer::setTcpTransportTryLockTimeout(uint64_t timeout) {
impl->setTcpTransportTryLockTimeout(timeout);
}
-const uint64_t DefaultMQPushConsumer::getTcpTransportTryLockTimeout() const {
+uint64_t DefaultMQPushConsumer::getTcpTransportTryLockTimeout() const {
return impl->getTcpTransportTryLockTimeout();
}
void DefaultMQPushConsumer::setAsyncPull(bool asyncFlag) {
diff --git a/src/include/DefaultMQClient.h b/src/include/DefaultMQClient.h
index ebf54a5..b1b51bd 100644
--- a/src/include/DefaultMQClient.h
+++ b/src/include/DefaultMQClient.h
@@ -138,7 +138,7 @@ class DefaultMQClient {
pullThreadNum = brokerNum*2
**/
void setTcpTransportPullThreadNum(int num);
- const int getTcpTransportPullThreadNum() const;
+ int getTcpTransportPullThreadNum() const;
/** timeout of tcp connect, it is same meaning for both producer and consumer;
1. default value is 3000ms
@@ -146,7 +146,7 @@ class DefaultMQClient {
1000-3000ms;
**/
void setTcpTransportConnectTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportConnectTimeout() const;
+ uint64_t getTcpTransportConnectTimeout() const;
/** timeout of tryLock tcpTransport before sendMsg/pullMsg, if timeout,
returns NULL
@@ -157,7 +157,7 @@ class DefaultMQClient {
will be setted to 1000ms
**/
void setTcpTransportTryLockTimeout(uint64_t timeout); // ms
- const uint64_t getTcpTransportTryLockTimeout() const;
+ uint64_t getTcpTransportTryLockTimeout() const;
void setUnitName(std::string unitName);
const std::string& getUnitName() const;
diff --git a/src/producer/DefaultMQProducer.cpp b/src/producer/DefaultMQProducer.cpp
index e5eb6ba..f656b1e 100644
--- a/src/producer/DefaultMQProducer.cpp
+++ b/src/producer/DefaultMQProducer.cpp
@@ -145,20 +145,20 @@ void DefaultMQProducer::setLogFileSizeAndNum(int fileNum, long perFileSize) {
void DefaultMQProducer::setTcpTransportPullThreadNum(int num) {
impl->setTcpTransportPullThreadNum(num);
}
-const int DefaultMQProducer::getTcpTransportPullThreadNum() const {
+int DefaultMQProducer::getTcpTransportPullThreadNum() const {
return impl->getTcpTransportPullThreadNum();
}
void DefaultMQProducer::setTcpTransportConnectTimeout(uint64_t timeout) {
impl->setTcpTransportConnectTimeout(timeout);
}
-const uint64_t DefaultMQProducer::getTcpTransportConnectTimeout() const {
+uint64_t DefaultMQProducer::getTcpTransportConnectTimeout() const {
return impl->getTcpTransportConnectTimeout();
}
void DefaultMQProducer::setTcpTransportTryLockTimeout(uint64_t timeout) {
impl->setTcpTransportTryLockTimeout(timeout);
}
-const uint64_t DefaultMQProducer::getTcpTransportTryLockTimeout() const {
+uint64_t DefaultMQProducer::getTcpTransportTryLockTimeout() const {
return impl->getTcpTransportTryLockTimeout();
}
diff --git a/src/producer/TransactionMQProducer.cpp b/src/producer/TransactionMQProducer.cpp
index 5d69afb..fe2b855 100644
--- a/src/producer/TransactionMQProducer.cpp
+++ b/src/producer/TransactionMQProducer.cpp
@@ -93,20 +93,20 @@ int TransactionMQProducer::getSendMsgTimeout() const {
void TransactionMQProducer::setTcpTransportPullThreadNum(int num) {
impl->setTcpTransportPullThreadNum(num);
}
-const int TransactionMQProducer::getTcpTransportPullThreadNum() const {
+int TransactionMQProducer::getTcpTransportPullThreadNum() const {
return impl->getTcpTransportPullThreadNum();
}
void TransactionMQProducer::setTcpTransportConnectTimeout(uint64_t timeout) {
impl->setTcpTransportConnectTimeout(timeout);
}
-const uint64_t TransactionMQProducer::getTcpTransportConnectTimeout() const {
+uint64_t TransactionMQProducer::getTcpTransportConnectTimeout() const {
return impl->getTcpTransportConnectTimeout();
}
void TransactionMQProducer::setTcpTransportTryLockTimeout(uint64_t timeout) {
impl->setTcpTransportTryLockTimeout(timeout);
}
-const uint64_t TransactionMQProducer::getTcpTransportTryLockTimeout() const {
+uint64_t TransactionMQProducer::getTcpTransportTryLockTimeout() const {
return impl->getTcpTransportTryLockTimeout();
}
int TransactionMQProducer::getCompressMsgBodyOverHowmuch() const {