@Test
public void testCompress() throws UnsupportedEncodingException {

    SnappyRpcCompressor compressor = new SnappyRpcCompressor();
    String s = "xxxxasdasdasd0as8d0asdkmasldjalsd";
    byte[] bs = compressor.compress(s.getBytes("utf-8"));
    Assert.assertNotNull(s);
    String s1 = new String(compressor.deCompress(bs), "utf-8");
    Assert.assertEquals(s, s1);
}