Skip to content

Commit afd4f56

Browse files
authored
[ISSUE #928] Fix C++ push consumer handle error code and change demo log level (#932)
1 parent 55e7dd2 commit afd4f56

File tree

3 files changed

+10
-5
lines changed

3 files changed

+10
-5
lines changed

cpp/examples/ExampleFifoProducer.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -105,8 +105,8 @@ int main(int argc, char* argv[]) {
105105
gflags::ParseCommandLineFlags(&argc, &argv, true);
106106

107107
auto& logger = getLogger();
108-
logger.setConsoleLevel(Level::Debug);
109-
logger.setLevel(Level::Debug);
108+
logger.setConsoleLevel(Level::Info);
109+
logger.setLevel(Level::Info);
110110
logger.init();
111111

112112
// Access Key/Secret pair may be acquired from management console
@@ -172,7 +172,7 @@ int main(int argc, char* argv[]) {
172172

173173
semaphore->acquire();
174174
producer.send(std::move(message), callback);
175-
std::cout << "Cached No." << i << " message" << std::endl;
175+
// std::cout << "Cached No." << i << " message" << std::endl;
176176
}
177177
} catch (...) {
178178
std::cerr << "Ah...No!!!" << std::endl;

cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,11 @@ void AsyncReceiveMessageCallback::onCompletion(const std::error_code& ec, const
5151
return;
5252
}
5353

54+
if (ec == ErrorCode::NoContent) {
55+
checkThrottleThenReceive();
56+
return;
57+
}
58+
5459
if (ec) {
5560
SPDLOG_WARN("Receive message from {} failed. Cause: {}. Retry after 1 second.", process_queue->simpleName(), ec.message());
5661
receiveMessageLater(std::chrono::seconds (1));

cpp/source/rocketmq/SimpleConsumerImpl.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -95,11 +95,11 @@ void SimpleConsumerImpl::start() {
9595
}
9696
};
9797

98-
// refer java sdk: set refresh interval to 30 seconds
98+
// refer java sdk: set refresh interval to 5 seconds
9999
// org.apache.rocketmq.client.java.impl.ClientImpl#startUp
100100
refresh_assignment_task_ = manager()->getScheduler()->schedule(
101101
refresh_assignment_task, "RefreshAssignmentTask",
102-
std::chrono::minutes(5), std::chrono::seconds(5));
102+
std::chrono::seconds(5), std::chrono::seconds(5));
103103

104104
client_manager_->addClientObserver(shared_from_this());
105105
}

0 commit comments

Comments
 (0)