@Before
  public void setUp() throws IOException { // Setup server for both protocols
    this.conf = HBaseConfiguration.create();
    this.conf.set(RpcServerFactory.CUSTOM_RPC_SERVER_IMPL_CONF_KEY, rpcServerImpl);
    Log4jUtils.setLogLevel("org.apache.hadoop.ipc.HBaseServer", "ERROR");
    Log4jUtils.setLogLevel("org.apache.hadoop.ipc.HBaseServer.trace", "TRACE");
    // Create server side implementation
    // Get RPC server for server side implementation
    this.server = RpcServerFactory.createRpcServer(null, "testrpc",
      Lists.newArrayList(new RpcServer.BlockingServiceAndInterface(SERVICE, null)),
      new InetSocketAddress(ADDRESS, PORT), conf, new FifoRpcScheduler(conf, 10));
    InetSocketAddress address = server.getListenerAddress();
    if (address == null) {
      throw new IOException("Listener channel is closed");
    }
    this.isa = address;
    this.server.start();
  }
Test for testing protocol buffer based RPC mechanism. This test depends on test.proto definition
of types in <code>src/test/protobuf/test.proto</code> and protobuf service definition from
<code>src/test/protobuf/test_rpc_service.proto</code>
hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestProtoBufRpc.java