[ISSUE #208]support request/reply model in rocketmq-spring #209

xiangwangcheng · 2019-12-20T08:47:17Z

What is the purpose of the change

add feature from #208

Brief changelog

add send request message method in RoketMQTemplate including:

in sync model
in sync model and send in orderly
) in async model
in aysnc model and send in ordery

and test cases.

Verifying this change

XXXX

Follow this checklist to help us incorporate your contribution quickly and easily. Notice, it would be helpful if you could finish the following 5 checklist(the last one is not necessary)before request the community to review your PR.

[√] Make sure there is a Github issue filed for the change (usually before you start working on it). Trivial changes like typos do not require a Github issue. Your pull request should address just this issue, without pulling in other changes - one PR resolves one issue.
[√] Format the pull request title like [ISSUE #123] Fix UnknownException when host config not exist. Each commit in the pull request should have a meaningful subject line and body.
[√] Write a pull request description that is detailed enough to understand what the pull request does, how, and why.
[√] Write necessary unit-test(over 80% coverage) to verify your logic correction, more mock a little better when cross module dependency exist.
[√] Run mvn -B clean apache-rat:check findbugs:findbugs checkstyle:checkstyle to make sure basic checks pass. Run mvn clean install -DskipITs to make sure unit-test pass. Run mvn clean test-compile failsafe:integration-test to make sure integration-test pass.
If this contribution is large, please file an Apache Individual Contributor License Agreement.

zongtanghu · 2019-12-23T08:41:12Z

please add some test cases to improve some code coverage, thanks.

zongtanghu · 2019-12-23T08:44:04Z

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

+            if (delayLevel > 0) {
+                rocketMsg.setDelayTimeLevel(delayLevel);
+            }
+            org.apache.rocketmq.common.message.Message replyMessage;


replyMessage variable can be initialized here.

And you can check the same issue at other places.

Actually, "variable initializer null here is reduncdant" warnings will show if we initialize null to it.

zongtanghu · 2019-12-23T08:52:36Z

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

+                charset, destination, message);
+            if (delayLevel > 0) {
+                rocketMsg.setDelayTimeLevel(delayLevel);
+            }


In the this method, there is need to check requestCallback is null?

I think null is allowed here because we may have the situation that do nothing when response comes back.

RongtongJin · 2019-12-24T08:37:00Z

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

+    public org.apache.rocketmq.common.message.Message requestSync(String destination, Message<?> message) {
+        return requestSync(destination, message, producer.getSendMsgTimeout());
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSync(String destination, Object payload) {
+        return requestSync(destination, payload, producer.getSendMsgTimeout());
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSync(String destination, Message<?> message, long timeout) {
+        return requestSync(destination, message, timeout, 0);
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSync(String destination, Object payload, long timeout) {
+        return requestSync(destination, payload, timeout, 0);
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSync(String destination, Message<?> message, long timeout, int delayLevel) {
+        if (Objects.isNull(message) || Objects.isNull(message.getPayload())) {
+            log.error("send request message failed. destination:{}, message is null ", destination);
+            throw new IllegalArgumentException("`message` and `message.payload` cannot be null");
+        }
+
+        try {
+            org.apache.rocketmq.common.message.Message rocketMsg = RocketMQUtil.convertToRocketMessage(rocketMQMessageConverter.getMessageConverter(),
+                charset, destination, message);
+            if (delayLevel > 0) {
+                rocketMsg.setDelayTimeLevel(delayLevel);
+            }
+            org.apache.rocketmq.common.message.Message replyMessage;
+            replyMessage = producer.request(rocketMsg, timeout);
+            return replyMessage;
+        } catch (Exception e) {
+            log.error("send request message failed. destination:{}, message:{} ", destination, message);
+            throw new MessagingException(e.getMessage(), e);
+        }
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSync(String destination, Object payload, long timeout, int delayLevel) {
+        Message<?> message = MessageBuilder.withPayload(payload).build();
+        return requestSync(destination, message, timeout, delayLevel);
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSyncOrderly(String destination, Message<?> message, String hashKey) {
+        return requestSyncOrderly(destination, message, hashKey, producer.getSendMsgTimeout());
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSyncOrderly(String destination, Object payload, String hashKey) {
+        return requestSyncOrderly(destination, payload, hashKey, producer.getSendMsgTimeout());
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSyncOrderly(String destination, Message<?> message, String hashKey, long timeout) {
+        return requestSyncOrderly(destination, message, hashKey, timeout, 0);
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSyncOrderly(String destination, Object payload, String hashKey, long timeout) {
+        return requestSyncOrderly(destination, payload, hashKey, timeout, 0);
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSyncOrderly(String destination, Message<?> message, String hashKey, long timeout, int delayLevel) {
+        if (Objects.isNull(message) || Objects.isNull(message.getPayload())) {
+            log.error("send request message failed. destination:{}, message is null ", destination);
+            throw new IllegalArgumentException("`message` and `message.payload` cannot be null");
+        }
+
+        try {
+            org.apache.rocketmq.common.message.Message rocketMsg = RocketMQUtil.convertToRocketMessage(rocketMQMessageConverter.getMessageConverter(),
+                charset, destination, message);
+            if (delayLevel > 0) {
+                rocketMsg.setDelayTimeLevel(delayLevel);
+            }
+            org.apache.rocketmq.common.message.Message replyMessage;
+            if (Objects.isNull(hashKey) || hashKey.isEmpty()) {
+                replyMessage = producer.request(rocketMsg, timeout);
+            } else {
+                replyMessage = producer.request(rocketMsg, messageQueueSelector, hashKey, timeout);
+            }
+            return replyMessage;
+        } catch (Exception e) {
+            log.error("send request message failed. destination:{}, message:{} ", destination, message);
+            throw new MessagingException(e.getMessage(), e);
+        }
+    }
+
+    public org.apache.rocketmq.common.message.Message requestSyncOrderly(String destination, Object payload, String hashKey, long timeout, int delayLevel) {
+        Message<?> message = MessageBuilder.withPayload(payload).build();
+        return requestSyncOrderly(destination, message, hashKey, timeout, delayLevel);
+    }
+
+    public void requestAsync(String destination, Message<?> message, RequestCallback requestCallback) {
+        requestAsync(destination, message, requestCallback, producer.getSendMsgTimeout());
+    }
+
+    public void requestAsync(String destination, Object payload, RequestCallback requestCallback) {
+        Message<?> message = MessageBuilder.withPayload(payload).build();
+        requestAsync(destination, message, requestCallback, producer.getSendMsgTimeout());
+    }
+
+    public void requestAsync(String destination, Message<?> message, RequestCallback requestCallback, long timeout) {
+        requestAsync(destination, message, requestCallback, timeout, 0);
+    }
+
+    public void requestAsync(String destination, Object payload, RequestCallback requestCallback, long timeout) {
+        requestAsync(destination, payload, requestCallback, timeout, 0);
+    }
+
+    public void requestAsync(String destination, Message<?> message, RequestCallback requestCallback, long timeout, int delayLevel) {
+        if (Objects.isNull(message) || Objects.isNull(message.getPayload())) {
+            log.error("send request message failed. destination:{}, message is null ", destination);
+            throw new IllegalArgumentException("`message` and `message.payload` cannot be null");
+        }
+
+        try {
+            org.apache.rocketmq.common.message.Message rocketMsg = RocketMQUtil.convertToRocketMessage(rocketMQMessageConverter.getMessageConverter(),
+                charset, destination, message);
+            if (delayLevel > 0) {
+                rocketMsg.setDelayTimeLevel(delayLevel);
+            }
+            producer.request(rocketMsg, requestCallback, timeout);
+        } catch (Exception e) {
+            log.error("send request message failed. destination:{}, message:{} ", destination, message);
+            throw new MessagingException(e.getMessage(), e);
+        }
+    }
+
+    public void requestAsync(String destination, Object payload, RequestCallback requestCallback, long timeout, int delayLevel) {
+        Message<?> message = MessageBuilder.withPayload(payload).build();
+        requestAsync(destination, message, requestCallback, producer.getSendMsgTimeout(), delayLevel);
+    }
+
+    public void requestAsyncOrderly(String destination, Message<?> message, RequestCallback requestCallback, String hashKey) {
+        requestAsyncOrderly(destination, message, requestCallback, hashKey, producer.getSendMsgTimeout());
+    }
+
+    public void requestAsyncOrderly(String destination, Object payload, RequestCallback requestCallback, String hashKey) {
+        requestAsyncOrderly(destination, payload, requestCallback, hashKey, producer.getSendMsgTimeout());
+    }
+
+    public void requestAsyncOrderly(String destination, Message<?> message, RequestCallback requestCallback, String hashKey, long timeout) {
+        requestAsyncOrderly(destination, message, requestCallback, hashKey, timeout, 0);
+    }
+
+    public void requestAsyncOrderly(String destination, Object payload, RequestCallback requestCallback, String hashKey, long timeout) {
+        requestAsyncOrderly(destination, payload, requestCallback, hashKey, timeout, 0);
+    }
+
+    public void requestAsyncOrderly(String destination, Message<?> message, RequestCallback requestCallback, String hashKey, long timeout, int delayLevel) {
+        if (Objects.isNull(message) || Objects.isNull(message.getPayload())) {
+            log.error("send request message failed. destination:{}, message is null ", destination);
+            throw new IllegalArgumentException("`message` and `message.payload` cannot be null");
+        }
+
+        try {
+            org.apache.rocketmq.common.message.Message rocketMsg = RocketMQUtil.convertToRocketMessage(rocketMQMessageConverter.getMessageConverter(),
+                charset, destination, message);
+            if (delayLevel > 0) {
+                rocketMsg.setDelayTimeLevel(delayLevel);
+            }
+            if (Objects.isNull(hashKey) || hashKey.isEmpty()) {
+                producer.request(rocketMsg, requestCallback, timeout);
+            } else {
+                producer.request(rocketMsg, messageQueueSelector, hashKey, requestCallback, timeout);
+            }
+        } catch (Exception e) {
+            log.error("send request message failed. destination:{}, message:{} ", destination, message);
+            throw new MessagingException(e.getMessage(), e);
+        }
+    }
+
+    public void requestAsyncOrderly(String destination, Object payload, RequestCallback requestCallback, String hashKey, long timeout, int delayLevel) {
+        Message<?> message = MessageBuilder.withPayload(payload).build();
+        requestAsyncOrderly(destination, message, requestCallback, hashKey, producer.getSendMsgTimeout(), delayLevel);
+    }
+
    /**
     * <p> Send message in synchronous mode. This method returns only when the sending procedure totally completes.
     * Reliable synchronous transmission is used in extensive scenes, such as important notification messages, SMS


[Discuss] Sending spring message but returning rocketmq message may not be friendly for users, especially the full name of rocketmq message is so long. Do we need to expose rocketmq message to users？

IMO, there are too many method names. Keep the same name, such as 'sendAndReceive ' and use different parameters to distinguish different types of methods.

[Discuss] Sending spring message but returning rocketmq message may not be friendly for users, especially the full name of rocketmq message is so long. Do we need to expose rocketmq message to users？

Yeah, I am not sure about that too, but I think users MAY need the attributes in RocketMQ Message, such as topic/properties.

IMO, there are too many method names. Keep the same name, such as 'sendAndReceive ' and use different parameters to distinguish different types of methods.

I have thought about that in the first place. But I changed my mind because the current implementation will make the code simple and more friendly to users.
(Seems sendXXOrdery method can be merged sendXXX, but can not merge requestSync and requestAsync because of different return types the sync mode and async mode. )

RongtongJin · 2019-12-24T08:51:18Z

...me-demo/src/main/java/org/apache/rocketmq/samples/springboot/consumer/ConsumerWithReply.java

+@Service
+@RocketMQMessageListener(topic = "${demo.rocketmq.requestTopic}", consumerGroup = "request_consumer", selectorExpression = "${demo.rocketmq.tag}")
+public class ConsumerWithReply implements RocketMQListener<MessageExt> {
+
+    @Autowired
+    private DefaultMQProducer replyProducer;
+
+    @Override
+    public void onMessage(MessageExt message) {
+        System.out.printf("------- StringConsumer received: %s \n", message);
+        try {
+            String replyTo = MessageUtil.getReplyToClient(message);
+            byte[] replyContent = "reply message contents.".getBytes();
+            // create reply message with given util, do not create reply message by yourself
+            Message replyMessage = MessageUtil.createReplyMessage(message, replyContent);
+
+            // send reply message with producer
+            SendResult replyResult = replyProducer.send(replyMessage, 3000);
+            System.out.printf("reply to %s , %s %n", replyTo, replyResult.toString());
+        }catch(MQClientException | RemotingException | MQBrokerException | InterruptedException e) {
+            System.out.println(e.getLocalizedMessage());
+        }
+    }
+}


If the user use RocketMQListener to receive message, he will not be able to use request-reply model according to current implementation. IMO, for consumer, we needs to implement a new interface, such as

public interface RocketMQReplyListener<T> { Message<?> onMessage(T message); }

and the job of reply message does not need to be completed by the user.

Good idea! I will think about it.

vongosling · 2019-12-25T03:20:54Z

...me-demo/src/main/java/org/apache/rocketmq/samples/springboot/consumer/ConsumerWithReply.java

+import org.springframework.stereotype.Service;
+
+/**
+ * RocketMQMessageListener


Useless comments, Could you add some more concrete comments for this class

vongosling · 2019-12-25T03:23:02Z

...me-demo/src/main/java/org/apache/rocketmq/samples/springboot/consumer/ConsumerWithReply.java

+ * RocketMQMessageListener
+ */
+@Service
+@RocketMQMessageListener(topic = "${demo.rocketmq.requestTopic}", consumerGroup = "request_consumer", selectorExpression = "${demo.rocketmq.tag}")


Is it better off using placeholder instead of the concrete group request_consumer?

xiangwangcheng · 2020-01-05T17:42:36Z

I have made some changes after referring to the implementation of Kafka-spring.

reduce the number of methods
use generic type to receive reply content
add a new interface RocketMQReplyListener for consuming and replying.
conceal the reply logic in consumer side.

@vongosling @RongtongJin @zongtanghu @duhenglucky

RongtongJin · 2020-01-07T02:37:56Z

...-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java

+                    if (sendResult.getSendStatus() != SendStatus.SEND_OK) {
+                        log.error("Consumer replys message failed. SendStatus: {}", sendResult.getSendStatus());
+                    } else {
+                        log.info("Consumer replys message success.");
+                    }
+                }
+
+                @Override public void onException(Throwable e) {
+                    log.error("Consumer replys message failed. error: {}", e.getLocalizedMessage());


Consumer replys message -> Consumer reply message

Is replies correct?

RongtongJin · 2020-01-07T02:57:57Z

.../src/main/java/org/apache/rocketmq/samples/springboot/consumer/ConsumerWithReplyGeneric.java

+/**
+ * RocketMQMessageListener
+ */


useless comment

RongtongJin · 2020-01-07T03:02:45Z

...c/main/java/org/apache/rocketmq/samples/springboot/consumer/ObjectConsumerWithReplyUser.java

+/**
+ * Consumer that support request-response model
+ */


request-response change to request-reply

RongtongJin · 2020-01-07T03:06:33Z

...main/java/org/apache/rocketmq/samples/springboot/consumer/StringConsumerWithReplyString.java

+/**
+ * Consumer that support request-response model
+ */


Same as above

RongtongJin · 2020-01-07T03:34:02Z

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQReplyListener.java

+/**
+ * The consumer supported request-response model should implement this interface.
+ *


The consumer supporting request-reply should implement this interface. is better

RongtongJin · 2020-01-07T03:38:29Z

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQReplyListener.java

+/**
+ * The consumer supported request-response model should implement this interface.
+ *
+ * @param <T> the type received by the listener


I think we should also comment param <R> .

RongtongJin · 2020-01-07T03:42:19Z

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

+    private Message<?> validateMessageAndPayload(Message<?> message, Object payload) {
+        if (Objects.nonNull(message) && Objects.nonNull(payload)) {
+            log.error("`message` and `payload` cannot exist at the same time.");
+            throw new IllegalArgumentException("`message` and `payload` cannot exist at the same time");
+        }
+
+        if (Objects.nonNull(payload)) {
+            message = MessageBuilder.withPayload(payload).build();
+        }
+
+        if (Objects.isNull(message) || Objects.isNull(message.getPayload())) {
+            log.error("send request message failed. Either `message` or `payload` needed.");
+            throw new IllegalArgumentException("either `message` or `payload` needed.");
+        }
+        return message;
+    }


Delete useless method

RongtongJin · 2020-01-07T03:46:10Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

+        rocketMQTemplate.sendAndReceive(stringRequestTopic, "request string", new RequestCallback() {
+            @Override public void onSuccess(org.apache.rocketmq.common.message.Message message) {
+                System.out.print("receive reply content in callback: " + message.toString());
+            }
+
+            @Override public void onException(Throwable e) {
+                e.printStackTrace();
+            }
+        });


[Important] we need to switch RequestCallback, because rocketmq message expose to users.

Thanks for these comments, I will consider that and make another commit.

RongtongJin · 2020-01-07T03:48:53Z

...-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java

+        }
+    }
+
+    private void handleReplyMessage(


How about change a method name? because it is not just about handling reply message.

RongtongJin · 2020-01-08T11:49:59Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

+        System.out.printf("send %s and receive %s %n", "request byte[]", replyBytes.toString());
+
+        // send request in sync mode with hashKey parameter and receive a reply of User type.
+        User requestUser = new User().setUserAge(Byte.valueOf((byte) 9)).setUserName("requestUserName");


Byte.valueOf((byte) 9) --> (byte) 9

RongtongJin · 2020-01-08T11:58:23Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

+    class RocketMQRequestCallbackImpl_User implements RocketMQLocalRequestCallback<User> {
+        @Override public void onSuccess(User message) {
+            System.out.println("receive User: " + message.toString());
+        }
+
+        @Override public void onException(Throwable e) {
+            e.printStackTrace();
+        }
+    }


Delete useless class

RongtongJin · 2020-01-09T03:22:50Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

+        System.out.printf("send %s and receive %s %n", "request string", replyString);
+
+        // send request in sync mode with timeout parameter and receive a reply of byte[] type.
+        byte[] replyBytes = rocketMQTemplate.sendAndReceive(bytesRequestTopic, new Message<String>() {


It would be better to use MessageBuilder.withPayload("request byte[]").build().

RongtongJin · 2020-01-09T03:24:44Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

        // Send transactional messages using extRocketMQTemplate
        testExtRocketMQTemplateTransaction();
+
+        // send request in sync mode and receive a reply of String type.


It would be better to capitalize first letter of comments

RongtongJin · 2020-01-09T03:27:23Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

+        rocketMQTemplate.sendAndReceive(stringRequestTopic, "request string", new RocketMQLocalRequestCallback<String>() {
+            @Override public void onSuccess(String message) {
+                System.out.println("receive string: " + message);
+            }
+
+            @Override public void onException(Throwable e) {
+                e.printStackTrace();
+            }
+        });
+        // send request in async mode and receive a reply of User type.
+        rocketMQTemplate.sendAndReceive(objectRequestTopic, new User().setUserAge((byte) 9).setUserName("requestUserName"), new RocketMQLocalRequestCallback<User>() {
+            @Override public void onSuccess(User message) {
+                System.out.println("receive User: " + message.toString());
+            }
+
+            @Override public void onException(Throwable e) {
+                e.printStackTrace();
+            }
+        }, 5000);


It would be better to use System.out.printf instead of System.out.println

RongtongJin · 2020-01-09T03:30:12Z

...q-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java

+                return null;
+            }
+        }, byte[].class, 3000);
+        System.out.printf("send %s and receive %s %n", "request byte[]", replyBytes.toString());


new String(replyBytes) instead of replyBytes.toString()

RongtongJin · 2020-01-09T03:31:34Z

...c/main/java/org/apache/rocketmq/samples/springboot/consumer/ObjectConsumerWithReplyUser.java

+    public User onMessage(User user) {
+        System.out.printf("------- ObjectConsumerWithReplyUser received: %s \n", user);
+        User replyUser = new User();
+        replyUser.setUserAge(Byte.valueOf((byte) 10));


(byte) 10 instead of Byte.valueOf((byte) 10)

@RongtongJin all fixed

xiangwangcheng force-pushed the master branch from 8657209 to 276f088 Compare December 20, 2019 09:18

zongtanghu reviewed Dec 23, 2019

View reviewed changes

vongosling changed the title ~~[ISSUE #208]support request/response model in rocketmq-spring~~ [ISSUE #208]support request/reply model in rocketmq-spring Dec 24, 2019

RongtongJin reviewed Dec 24, 2019

View reviewed changes

RongtongJin added the feature label Dec 24, 2019

vongosling reviewed Dec 25, 2019

View reviewed changes

chengxiangwang added 3 commits January 6, 2020 00:57

support request/response model in rocketmq-spring

b14b65d

fix checkstyle problem

3252e1a

add more test cases

29086c4

xiangwangcheng force-pushed the master branch from 9e0a3f9 to fe17906 Compare January 5, 2020 17:32

optimize request/reply model

250db87

xiangwangcheng force-pushed the master branch from fe17906 to 250db87 Compare January 6, 2020 14:17

add examples to ProduceApplication.java

747352c

RongtongJin reviewed Jan 7, 2020

View reviewed changes

chengxiangwang added 2 commits January 8, 2020 15:23

wrap RequestCallback to conceal RocketMQ message

be6a64c

requestCallback as method parameter

9ceb1df

RongtongJin reviewed Jan 8, 2020

View reviewed changes

delete useless class

d03451a

RongtongJin approved these changes Jan 9, 2020

View reviewed changes

RongtongJin added this to the 2.1.0 milestone Jan 10, 2020

fix some comments and print format

fbca7f6

vongosling approved these changes Jan 15, 2020

View reviewed changes

vongosling merged commit 64f149b into apache:master Jan 15, 2020

Denovo1998 mentioned this pull request Aug 18, 2024

[improve][broker] PIP-371: Support for request-reply model that implements RPC calls apache/pulsar#23194

Closed

15 tasks

[ISSUE #208]support request/reply model in rocketmq-spring #209

[ISSUE #208]support request/reply model in rocketmq-spring #209

Uh oh!

Conversation

xiangwangcheng commented Dec 20, 2019

What is the purpose of the change

Brief changelog

Verifying this change

Uh oh!

zongtanghu commented Dec 23, 2019

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

xiangwangcheng commented Jan 5, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

RongtongJin Jan 7, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

xiangwangcheng commented Jan 5, 2020 •

edited

Loading

RongtongJin Jan 7, 2020 •

edited

Loading