From 398e2ec382a2821c5fd068521c85b5901e9ffec0 Mon Sep 17 00:00:00 2001
From: forgive_dengkai <forgive_dengkai@163.com>
Date: Mon, 7 Aug 2023 14:08:53 +0800
Subject: [PATCH] change log

Signed-off-by: forgive_dengkai <forgive_dengkai@163.com>
---
 .../src/main/java/com/osx/broker/consumer/UnaryConsumer.java    | 2 +-
 .../src/main/java/com/osx/broker/eggroll/CommandClient.java     | 2 +-
 .../src/main/java/com/osx/broker/eggroll/PushEventHandler.java  | 2 +-
 .../src/test/java/com/osx/broker/test/grpc/NewFateTest.java     | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/java/osx/osx-broker/src/main/java/com/osx/broker/consumer/UnaryConsumer.java b/java/osx/osx-broker/src/main/java/com/osx/broker/consumer/UnaryConsumer.java
index 6522f50a9a..bca36312d0 100644
--- a/java/osx/osx-broker/src/main/java/com/osx/broker/consumer/UnaryConsumer.java
+++ b/java/osx/osx-broker/src/main/java/com/osx/broker/consumer/UnaryConsumer.java
@@ -162,7 +162,7 @@ public static class LongPullingHold {
         long needOffset;
 
         public  void  answer(Osx.Outbound  consumeResponse){
-            logger.info("============ answer long pulling========");
+
 
             if(streamObserver!=null) {
 
diff --git a/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/CommandClient.java b/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/CommandClient.java
index fb98d14754..e9f3e0917a 100644
--- a/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/CommandClient.java
+++ b/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/CommandClient.java
@@ -65,7 +65,7 @@ public Command.CommandResponse call(CommandURI commandUri, BaseProto... baseProt
                 .addAllArgs(Arrays.stream(baseProtos).
                         map((element) -> ((AbstractMessageLite) element.toProto()).toByteString()).collect(Collectors.toList()))
                 .build();
-        logger.info("===call {} {} id {}", erEndpoint.host, erEndpoint.port, id);
+
 
         ManagedChannel managedChannel = buildManagedChannel(erEndpoint.host, erEndpoint.port);
         CommandServiceGrpc.CommandServiceBlockingStub stub = CommandServiceGrpc.newBlockingStub(managedChannel);
diff --git a/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/PushEventHandler.java b/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/PushEventHandler.java
index 3bb8356764..03262cb65f 100644
--- a/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/PushEventHandler.java
+++ b/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/PushEventHandler.java
@@ -124,7 +124,7 @@ protected  void  handleMessage(MessageExt messageExt){
             putBatchSinkPushReqSO.onNext(tbBatch);
 
         }catch(Exception e){
-            logger.error("======handle msg error : "+ messageExt.getTopic(),e);
+            logger.error("handle msg error : "+ messageExt.getTopic(),e);
             if(backBlockingStub!=null) {
                 Osx.Inbound.Builder inboundBuilder = TransferUtil.buildInbound(provider,desPartyId, srcPartyId, TargetMethod.PRODUCE_MSG.name(),
                         backTopic, MessageFlag.ERROR, sessionId, ErrorMessageUtil.buildRemoteRpcErrorMsg(1343,"kkkkk").getBytes());
diff --git a/java/osx/osx-broker/src/test/java/com/osx/broker/test/grpc/NewFateTest.java b/java/osx/osx-broker/src/test/java/com/osx/broker/test/grpc/NewFateTest.java
index 6de3f3b16e..f9694fdf63 100644
--- a/java/osx/osx-broker/src/test/java/com/osx/broker/test/grpc/NewFateTest.java
+++ b/java/osx/osx-broker/src/test/java/com/osx/broker/test/grpc/NewFateTest.java
@@ -91,7 +91,7 @@ public void testUnaryCall(byte[] data){
 
     @Test
     public void testStream(){
-        System.err.println("==========================");
+
         io.grpc.stub.StreamObserver<org.ppc.ptp.Osx.Inbound>  reqSb = stub.transport(new StreamObserver<Osx.Outbound>() {
             @Override
             public void onNext(Osx.Outbound outbound) {