Examples of stopThriftServer()

Examples of com.netflix.priam.utils.JMXNodeTool.stopThriftServer()

337
338
339
340
341
342
343
344
345
346
347
      nodetool = JMXNodeTool.instance(config);
    } catch (JMXConnectionException e) {
      return Response.status(503).entity("JMXConnectionException")
          .build();
    }
        nodetool.stopThriftServer();
        return Response.ok(REST_SUCCESS, MediaType.APPLICATION_JSON).build();
    }

    @GET
    @Path("/enablethrift")
View Full Code Here

Examples of com.netflix.priam.utils.JMXNodeTool.stopThriftServer()

337
338
339
340
341
342
343
344
345
346
347
      nodetool = JMXNodeTool.instance(config);
    } catch (JMXConnectionException e) {
      return Response.status(503).entity("JMXConnectionException")
          .build();
    }
        nodetool.stopThriftServer();
        return Response.ok(REST_SUCCESS, MediaType.APPLICATION_JSON).build();
    }

    @GET
    @Path("/enablethrift")
View Full Code Here

Examples of com.xiaomi.infra.chronos.ChronosServer.stopThriftServer()

83
84
85
86
87
88
89
90
91
92
93
    TProtocol protocol = new TBinaryProtocol(transport);
    ChronosService.Client client = new ChronosService.Client(protocol);
    client.getTimestamp();
    transport.close();

    chronosServer.stopThriftServer();
    assert true;

    chronosServer.getFailoverWatcher().close();
  }
View Full Code Here

Examples of com.xiaomi.infra.chronos.ChronosServer.stopThriftServer()

87
88
89
90
91
92
93
94
95
96
97
    Thread.sleep(500); // wait for server to start
    ChronosClientWatcher chronosClientWatcher = createChronosClientWatcher();
    chronosClientWatcher.getTimestamp();
   
    chronosServer.stopThriftServer();
    chronosServer.getFailoverWatcher().close();
    chronosClientWatcher.close();
    assertTrue(true);
  }
View Full Code Here

Examples of com.xiaomi.infra.chronos.ChronosServer.stopThriftServer()

79
80
81
82
83
84
85
86
87
88
89
    ChronosClient chronosClient = createChronosServer();
    long timestamp1 = chronosClient.getTimestamp();
    long timestamp2 = chronosClient.getTimestamp();
    assertTrue(timestamp1 < timestamp2);
   
    chronosServer.stopThriftServer();
    chronosServer.getFailoverWatcher().close();
    chronosClient.getChronosClientWatcher().close();
  }
 
  @Test
View Full Code Here

Examples of com.xiaomi.infra.chronos.ChronosServer.stopThriftServer()

101
102
103
104
105
106
107
108
109
110
111
    ChronosClient chronosClient = createChronosServer();
    long timestamp1 = chronosClient.getTimestamps(100);
    long timestamp2 = chronosClient.getTimestamps(100);
    assertTrue(timestamp2 - timestamp1 >= 100);

    chronosServer.stopThriftServer();
    chronosServer.getFailoverWatcher().close();
    chronosClient.getChronosClientWatcher().close();
  }

}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.