diff --git a/example/src/main/java/org/apache/rocketmq/example/rpc/RequestProducer.java b/example/src/main/java/org/apache/rocketmq/example/rpc/RequestProducer.java index 73397738d59a6c52ea6727ba232994b9065a800f..a83f1db87f41f75ea38ea378cf55faf682f4693b 100644 --- a/example/src/main/java/org/apache/rocketmq/example/rpc/RequestProducer.java +++ b/example/src/main/java/org/apache/rocketmq/example/rpc/RequestProducer.java @@ -38,14 +38,14 @@ public class RequestProducer { producer.start(); try { - Message msg = new Message(topic, - "", - "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET)); + Message msg = new Message(topic, + "", + "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET)); - long begin = System.currentTimeMillis(); - Message retMsg = producer.request(msg, ttl); - long cost = System.currentTimeMillis() - begin; - System.err.printf("request to <%s> cost: %d replyMessage: %s %n", topic, cost, retMsg); + long begin = System.currentTimeMillis(); + Message retMsg = producer.request(msg, ttl); + long cost = System.currentTimeMillis() - begin; + System.err.printf("request to <%s> cost: %d replyMessage: %s %n", topic, cost, retMsg); } catch (Exception e) { log.warn("", e); }