Home Original page

refactor(warning): remove warnings in header files by ShannonDing · Pull Request #251 · apache/rocketmq-client-cpp

6 changes: 3 additions & 3 deletions include/DefaultMQProducer.h

Original file line number Diff line number Diff line change
Expand Up @@ -113,15 +113,15 @@ 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
* 2. input parameter could only be milliSecond, suggestion value is
* 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
Expand All @@ -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;
Expand Down

6 changes: 3 additions & 3 deletions include/DefaultMQPushConsumer.h

Original file line number Diff line number Diff line change
Expand Up @@ -107,15 +107,15 @@ 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
* 2. input parameter could only be milliSecond, suggestion value is
* 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
Expand All @@ -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;
Expand Down

6 changes: 3 additions & 3 deletions include/TransactionMQProducer.h

Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

6 changes: 3 additions & 3 deletions src/common/DefaultMQClient.cpp

Original file line number Diff line number Diff line change
Expand Up @@ -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;
}

Expand All @@ -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;
}

Expand Down

6 changes: 3 additions & 3 deletions src/consumer/DefaultMQPushConsumer.cpp

Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

6 changes: 3 additions & 3 deletions src/include/DefaultMQClient.h

Original file line number Diff line number Diff line change
Expand Up @@ -138,15 +138,15 @@ 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
2. input parameter could only be milliSecond, suggestion value is
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
Expand All @@ -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;
Expand Down

6 changes: 3 additions & 3 deletions src/producer/DefaultMQProducer.cpp

Original file line number Diff line number Diff line change
Expand Up @@ -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();
}

Expand Down

6 changes: 3 additions & 3 deletions src/producer/TransactionMQProducer.cpp

Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down