From d72e0307f0e669a09216ab93fa98e0bbe188458c Mon Sep 17 00:00:00 2001 From: sheyanjie-qq <249478495@qq.com> Date: Mon, 12 Aug 2024 17:44:23 +0800 Subject: [PATCH] mod rust log --- docs/examples/rust/restexample/examples/tmq.rs | 1 + .../main/java/com/taosdata/example/ConsumerLoopFull.java | 6 +++--- .../main/java/com/taosdata/example/WsConsumerLoopFull.java | 6 +++--- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/docs/examples/rust/restexample/examples/tmq.rs b/docs/examples/rust/restexample/examples/tmq.rs index 046e1ec59c..c828bd91ac 100644 --- a/docs/examples/rust/restexample/examples/tmq.rs +++ b/docs/examples/rust/restexample/examples/tmq.rs @@ -180,6 +180,7 @@ async fn main() -> anyhow::Result<()> { // ANCHOR: unsubscribe consumer.unsubscribe().await; + println!("consumer unsubscribed successfully."); // ANCHOR_END: unsubscribe tokio::time::sleep(Duration::from_secs(1)).await; diff --git a/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java b/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java index 64042ed309..39782e787c 100644 --- a/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java +++ b/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java @@ -72,10 +72,10 @@ public class ConsumerLoopFull { } catch (SQLException ex) { // handle any errors, please refer to the JDBC specifications for detailed exceptions info - System.out.println("Failed to poll data; ErrCode:" + ex.getErrorCode() + "; ErrMessage: " + ex.getMessage()); + System.out.println("Failed to poll data, ErrCode:" + ex.getErrorCode() + "; ErrMessage: " + ex.getMessage()); throw new SQLException("Failed to poll data", ex); } catch (Exception ex) { - System.out.println("Failed to poll data; ErrMessage: " + ex.getMessage()); + System.out.println("Failed to poll data, ErrMessage: " + ex.getMessage()); throw new SQLException("Failed to poll data", ex); } // ANCHOR_END: poll_data_code_piece @@ -149,7 +149,7 @@ public class ConsumerLoopFull { try { // unsubscribe the consumer consumer.unsubscribe(); - System.out.println("unsubscribe consumer successfully."); + System.out.println("consumer unsubscribed successfully."); } catch (SQLException ex) { // handle any errors, please refer to the JDBC specifications for detailed exceptions info System.out.println("Failed to unsubscribe consumer. ErrCode:" + ex.getErrorCode() + "; ErrMessage: " + ex.getMessage()); diff --git a/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java b/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java index 78f743b55d..45767f8461 100644 --- a/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java +++ b/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java @@ -70,10 +70,10 @@ public class WsConsumerLoopFull { } catch (SQLException ex) { // handle any errors, please refer to the JDBC specifications for detailed exceptions info - System.out.println("Failed to poll data; ErrCode:" + ex.getErrorCode() + "; ErrMessage: " + ex.getMessage()); + System.out.println("Failed to poll data, ErrCode:" + ex.getErrorCode() + "; ErrMessage: " + ex.getMessage()); throw new SQLException("Failed to poll data", ex); } catch (Exception ex) { - System.out.println("Failed to poll data; ErrMessage: " + ex.getMessage()); + System.out.println("Failed to poll data, ErrMessage: " + ex.getMessage()); throw new SQLException("Failed to poll data", ex); } // ANCHOR_END: poll_data_code_piece @@ -147,7 +147,7 @@ public class WsConsumerLoopFull { try { // unsubscribe the consumer consumer.unsubscribe(); - System.out.println("unsubscribe consumer successfully."); + System.out.println("consumer unsubscribed successfully."); } catch (SQLException ex) { // handle any errors, please refer to the JDBC specifications for detailed exceptions info System.out.println("Failed to unsubscribe consumer. ErrCode:" + ex.getErrorCode() + "; ErrMessage: " + ex.getMessage());