@Test
public void serviceOnTransactionStartTest() {

  final GrpcTccTransactionStartedEvent[] requestCaptor = new GrpcTccTransactionStartedEvent[1];
  TccStartedEvent event = new TccStartedEvent(globalTxId,localTxId);
  TccEventServiceImplBase serviceImpl = new TccEventServiceImplBase() {
    public void onTccTransactionStarted(GrpcTccTransactionStartedEvent request,
        io.grpc.stub.StreamObserver<GrpcAck> responseObserver) {
      requestCaptor[0] = request;
      responseObserver.onNext(ack);
      responseObserver.onCompleted();
    }
  };
  serviceRegistry.addService(serviceImpl);
  AlphaResponse response =service.tccTransactionStart(event);
  assertThat(requestCaptor[0].getServiceName(), is(serviceConfig.serviceName()));
  assertThat(requestCaptor[0].getInstanceId(), is(serviceConfig.instanceId()));
  assertThat(requestCaptor[0].getGlobalTxId(), is(globalTxId));
  assertThat(requestCaptor[0].getLocalTxId(), is(localTxId));
  assertThat(response.aborted(), is(false));
}