iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BAEL-702 - Intro to Vert.x formatting changes

Browse Source
This commit is contained in:
slavisa-baeldung 2017-03-20 15:50:43 +00:00
parent c071c59ada
commit 5294e7d425
5 changed files with 44 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
vertx/src/main/java/com/baeldung/HelloVerticle.java
View File

@ -10,6 +10,11 @@ import io.vertx.core.Vertx;
public class HelloVerticle extends AbstractVerticle { public class HelloVerticle extends AbstractVerticle {
private static final Logger LOGGER = LoggerFactory.getLogger(HelloVerticle.class); private static final Logger LOGGER = LoggerFactory.getLogger(HelloVerticle.class);
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
vertx.deployVerticle(new HelloVerticle());
}
@Override @Override
public void start(Future<Void> future) { public void start(Future<Void> future) {
LOGGER.info("Welcome to Vertx"); LOGGER.info("Welcome to Vertx");
@ -19,10 +24,5 @@ public class HelloVerticle extends AbstractVerticle {
public void stop() { public void stop() {
LOGGER.info("Shutting down application"); LOGGER.info("Shutting down application");
} }
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
vertx.deployVerticle(new HelloVerticle());
}
} }

24
vertx/src/main/java/com/baeldung/SimpleServerVerticle.java
View File

@ -4,21 +4,21 @@ import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future; import io.vertx.core.Future;
public class SimpleServerVerticle extends AbstractVerticle { public class SimpleServerVerticle extends AbstractVerticle {
@Override @Override
public void start(Future<Void> future) { public void start(Future<Void> future) {
vertx.createHttpServer() vertx.createHttpServer()
.requestHandler(request -> { .requestHandler(request -> {
request.response() request.response()
.end("Welcome to Vert.x Intro"); .end("Welcome to Vert.x Intro");
}) })
.listen(config().getInteger("http.port", 8080), result -> { .listen(config().getInteger("http.port", 8080), result -> {
if (result.succeeded()) { if (result.succeeded()) {
future.complete(); future.complete();
} else { } else {
future.fail(result.cause()); future.fail(result.cause());
} }
}); });
} }
} }

26
vertx/src/main/java/com/baledung/rest/RestServiceVerticle.java
View File

@ -14,28 +14,28 @@ public class RestServiceVerticle extends AbstractVerticle {
Router router = Router.router(vertx); Router router = Router.router(vertx);
router.get("/api/baeldung/articles/article/:id") router.get("/api/baeldung/articles/article/:id")
.handler(this::getArticles); .handler(this::getArticles);
vertx.createHttpServer() vertx.createHttpServer()
.requestHandler(router::accept) .requestHandler(router::accept)
.listen(config().getInteger("http.port", 8080), result -> { .listen(config().getInteger("http.port", 8080), result -> {
if (result.succeeded()) { if (result.succeeded()) {
future.complete(); future.complete();
} else { } else {
future.fail(result.cause()); future.fail(result.cause());
} }
}); });
} }
private void getArticles(RoutingContext routingContext) { private void getArticles(RoutingContext routingContext) {
String articleId = routingContext.request() String articleId = routingContext.request()
.getParam("id"); .getParam("id");
Article article = new Article(articleId, "This is an intro to vertx", "baeldung", "01-02-2017", 1578); Article article = new Article(articleId, "This is an intro to vertx", "baeldung", "01-02-2017", 1578);
routingContext.response() routingContext.response()
.putHeader("content-type", "application/json") .putHeader("content-type", "application/json")
.setStatusCode(200) .setStatusCode(200)
.end(Json.encodePrettily(article)); .end(Json.encodePrettily(article));
} }
} }

12
vertx/src/test/java/com/baeldung/RestServiceVerticleTest.java
View File

@ -34,13 +34,13 @@ public class RestServiceVerticleTest {
final Async async = testContext.async(); final Async async = testContext.async();
vertx.createHttpClient() vertx.createHttpClient()
.getNow(8080, "localhost", "/api/baeldung/articles/article/12345", response -> { .getNow(8080, "localhost", "/api/baeldung/articles/article/12345", response -> {
response.handler(responseBody -> { response.handler(responseBody -> {
testContext.assertTrue(responseBody.toString() testContext.assertTrue(responseBody.toString()
.contains("\"id\" : \"12345\"")); .contains("\"id\" : \"12345\""));
async.complete(); async.complete();
});
}); });
});
} }
} }

16
vertx/src/test/java/com/baeldung/SimpleServerVerticleTest.java
View File

@ -20,8 +20,8 @@ public class SimpleServerVerticleTest {
public void setup(TestContext testContext) { public void setup(TestContext testContext) {
vertx = Vertx.vertx(); vertx = Vertx.vertx();
vertx.deployVerticle(SimpleServerVerticle.class.getName(), vertx.deployVerticle(SimpleServerVerticle.class.getName(),
testContext.asyncAssertSuccess()); testContext.asyncAssertSuccess());
} }
@After @After
@ -34,13 +34,13 @@ public class SimpleServerVerticleTest {
final Async async = testContext.async(); final Async async = testContext.async();
vertx.createHttpClient() vertx.createHttpClient()
.getNow(8080, "localhost", "/", response -> { .getNow(8080, "localhost", "/", response -> {
response.handler(responseBody -> { response.handler(responseBody -> {
testContext.assertTrue(responseBody.toString() testContext.assertTrue(responseBody.toString()
.contains("Welcome")); .contains("Welcome"));
async.complete(); async.complete();
});
}); });
});
} }
} }