Guest User

Untitled

a guest
Apr 10th, 2018
118
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.83 KB | None | 0 0
  1. public class Client extends AbstractVerticle{
  2.  
  3. @Override
  4. public void start() throws Exception {
  5. final HttpClient httpClient = this.vertx.createHttpClient();
  6. this.vertx.setPeriodic(1000, handler->{
  7. httpClient.getNow(8080, "localhost", "/", responseHandler -> {
  8. System.out.println("response");
  9. });
  10. });
  11. }
  12.  
  13. }
  14.  
  15. public class JdbcVertx extends AbstractVerticle{
  16.  
  17. @Override
  18. public void start() throws Exception {
  19. JDBCClient client = JDBCClient.createNonShared(this.vertx, new JsonObject()
  20. .put("url", "jdbc:postgresql://localhost:5432/test")
  21. .put("user", "user")
  22. .put("password", "password")
  23. .put("driver_class", "org.postgresql.Driver")
  24. .put("max_pool_size", 30));
  25. this.vertx.createHttpServer()
  26. .requestHandler(r -> {
  27. client.getConnection(handler -> {
  28. final SQLConnection connection = handler.result();
  29. connection.execute(execute(), hndlr -> {
  30. connection.close(closehndlr -> {
  31. r.response().putHeader("content-type", "text/html").end("Response");
  32. });
  33. });
  34. });
  35. }).listen(8080);
  36. }
  37.  
  38. private String execute(){
  39. return "insert into rubish (name) values ('test')";
  40. }
  41. }
  42.  
  43. if(Thread.currentThread().getState != 'blocked' && sec != 30){
  44. this.object.getHandler().execute();
  45. } else if(sec == 30){
  46. Thread.currentThread.inerrupt();
  47. } else{
  48. sec++;
  49. }
Add Comment
Please, Sign In to add comment