add unit tests

src/test/java/com/xiaomi/infra/pegasus/client/TestPException.java

@@ -0,0 +1,26 @@
+// Copyright (c) 2019, Xiaomi, Inc.  All rights reserved.
+// This source code is licensed under the Apache License Version 2.0, which
+// can be found in the LICENSE file in the root directory of this source tree.
+
+package com.xiaomi.infra.pegasus.client;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class TestPException {
+  @Test
+  public void testThreadInterrupted() throws Exception {
+    PException ex = PException.threadInterrupted("test");
+    Assert.assertEquals(
+        "com.xiaomi.infra.pegasus.rpc.ReplicationException: ERR_THREAD_INTERRUPTED: [table=test] Thread is interrupted!",
+        ex.getMessage());
+  }
+
+  @Test
+  public void testTimeout() throws Exception {
+    PException ex = PException.timeout("test", 1000);
+    Assert.assertEquals(
+        "com.xiaomi.infra.pegasus.rpc.ReplicationException: ERR_TIMEOUT: [table=test, timeout=1000ms] Timeout on Future await!",
+        ex.getMessage());
+  }
+}