We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 61439c6 commit 0f4f87aCopy full SHA for 0f4f87a
rocketmq-client/examples/quickstart/consumer.rs
@@ -33,7 +33,7 @@ pub const TAG: &str = "*";
33
#[rocketmq::main]
34
pub async fn main() -> Result<()> {
35
//init logger
36
- //rocketmq_common::log::init_logger();
+ rocketmq_common::log::init_logger();
37
38
// create a producer builder with default configuration
39
let builder = DefaultMQPushConsumer::builder();
@@ -59,7 +59,6 @@ impl MessageListenerConcurrently for MyMessageListener {
59
) -> Result<ConsumeConcurrentlyStatus> {
60
for msg in msgs {
61
info!("Receive message: {:?}", msg);
62
- println!("Receive message: {:?}", msg);
63
}
64
Ok(ConsumeConcurrentlyStatus::ConsumeSuccess)
65
0 commit comments