diff --git a/.idea/compiler.xml b/.idea/compiler.xml index b73660a..1d24fa9 100644 --- a/.idea/compiler.xml +++ b/.idea/compiler.xml @@ -1,6 +1,6 @@ - + \ No newline at end of file diff --git a/src/main/java/ro/mihai/GreetingsService.java b/src/main/java/ro/mihai/GreetingsService.java index 2b24c2f..6a74f42 100644 --- a/src/main/java/ro/mihai/GreetingsService.java +++ b/src/main/java/ro/mihai/GreetingsService.java @@ -11,7 +11,7 @@ import com.twitter.util.Future; public class GreetingsService extends Service { @Override public Future apply(Request request) { - String greeting = "Hello " + request.getParam("name"); + String greeting = "Hello1 " + request.getParam("name"); Reader reader = Reader.fromBuf(new Buf.ByteArray(greeting.getBytes(), 0, greeting.length())); return Future.value(Response.apply(request.version(), Status.Ok(), reader)); } diff --git a/src/main/java/ro/mihai/Main.java b/src/main/java/ro/mihai/Main.java index 8a9dbba..49b836b 100644 --- a/src/main/java/ro/mihai/Main.java +++ b/src/main/java/ro/mihai/Main.java @@ -1,10 +1,14 @@ package ro.mihai; import com.twitter.finagle.Http; - public class Main { public static void main(String []args) { GreetingsService sServ = new GreetingsService(); - Http.serve(":8080", sServ); + Http.server().withAdmissionControl() + .concurrencyLimit(10, 0) + .serve(":8080", sServ); + System.out.println("seems that this is async .... so we wait for connections"); + while( true) ; } + }