Examples of org.apache.thrift.server.TServer.stop()

org.apache.thrift.server.TServer.stop()
Stop the server. This is optional on a per-implementation basis. Not all servers are required to be cleanly stoppable.

    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
    
    tserver.stop();
    t.join(100);
  }


  Callable<Object> callable;

View Full Code Here

    try {
      server.serve();
    } finally {
      log.info("Closing down everything.");


      server.stop();
    }
  }


  private static enum Protocol {
    JSON(new TJSONProtocol.Factory()),

View Full Code Here

    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
    
    tserver.stop();
    t.join(100);
  }
}

View Full Code Here

    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
    
    tserver.stop();
    t.join(100);
  }
}

View Full Code Here

      client.throwsError();
      fail("no exception thrown");
    } catch (ThriftSecurityException ex) {
      // expected
    }
    server.stop();
    thread.join();
  }
  
}

View Full Code Here

    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
    
    tserver.stop();
    t.join(100);
  }


  Callable<Object> callable;

View Full Code Here

    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
    
    tserver.stop();
    t.join(100);
  }
}

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.