Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class Client extends AbstractVerticle{
- @Override
- public void start() throws Exception {
- final HttpClient httpClient = this.vertx.createHttpClient();
- this.vertx.setPeriodic(1000, handler->{
- httpClient.getNow(8080, "localhost", "/", responseHandler -> {
- System.out.println("response");
- });
- });
- }
- }
- public class JdbcVertx extends AbstractVerticle{
- @Override
- public void start() throws Exception {
- JDBCClient client = JDBCClient.createNonShared(this.vertx, new JsonObject()
- .put("url", "jdbc:postgresql://localhost:5432/test")
- .put("user", "user")
- .put("password", "password")
- .put("driver_class", "org.postgresql.Driver")
- .put("max_pool_size", 30));
- this.vertx.createHttpServer()
- .requestHandler(r -> {
- client.getConnection(handler -> {
- final SQLConnection connection = handler.result();
- connection.execute(execute(), hndlr -> {
- connection.close(closehndlr -> {
- r.response().putHeader("content-type", "text/html").end("Response");
- });
- });
- });
- }).listen(8080);
- }
- private String execute(){
- return "insert into rubish (name) values ('test')";
- }
- }
- if(Thread.currentThread().getState != 'blocked' && sec != 30){
- this.object.getHandler().execute();
- } else if(sec == 30){
- Thread.currentThread.inerrupt();
- } else{
- sec++;
- }
Add Comment
Please, Sign In to add comment