You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2019/10/14 03:01:08 UTC
[rocketmq-client-cpp] branch master updated: chore(example): make
more sense for output
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 9fa724e chore(example): make more sense for output
9fa724e is described below
commit 9fa724eadfc78b61220ca4bdb314db45ecc830d5
Author: vongosling <vo...@apache.org>
AuthorDate: Mon Oct 14 11:00:54 2019 +0800
chore(example): make more sense for output
---
example/Producer.c | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/example/Producer.c b/example/Producer.c
index 5d5c549..9ae23a9 100644
--- a/example/Producer.c
+++ b/example/Producer.c
@@ -58,17 +58,16 @@ void StartSendMessage(CProducer* producer) {
}
int main(int argc, char* argv[]) {
- printf("Producer initializing ...\n");
CProducer* producer = CreateProducer("Group_producer");
SetProducerNameServerAddress(producer, "127.0.0.1:9876");
StartProducer(producer);
+ printf("Producer initialized. \n");
- printf("Producer starting ...\n");
StartSendMessage(producer);
- printf("Producer stopping !\n");
ShutdownProducer(producer);
DestroyProducer(producer);
+ printf("Producer stopped !\n");
return 0;
}