From 6a73c0199b9265a705c6d202ac3cac13477f8ec9 Mon Sep 17 00:00:00 2001 From: Mihai Moldovanu Date: Sat, 30 Jul 2022 21:36:32 +0300 Subject: [PATCH] test --- build.gradle | 8 +++++--- src/main/java/ro/mihai/Main.java | 20 ++++++++++++++------ 2 files changed, 19 insertions(+), 9 deletions(-) diff --git a/build.gradle b/build.gradle index 49eb35b..dfc2871 100644 --- a/build.gradle +++ b/build.gradle @@ -12,9 +12,11 @@ repositories { dependencies { implementation 'com.google.inject:guice:5.1.0' - implementation 'com.twitter:finagle-http_2.12:22.7.0' - implementation 'com.twitter:finagle-thrift_2.11:21.2.0' - implementation 'io.netty:netty-transport:4.1.77.Final' + implementation 'com.twitter:finagle-http2_2.13:22.4.0' + implementation 'com.twitter:finagle-core_2.10:6.35.0' + + implementation 'com.twitter:finagle-http_2.13:22.4.0' + testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.2' testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.8.2' } diff --git a/src/main/java/ro/mihai/Main.java b/src/main/java/ro/mihai/Main.java index 74eccfa..2989625 100644 --- a/src/main/java/ro/mihai/Main.java +++ b/src/main/java/ro/mihai/Main.java @@ -1,26 +1,34 @@ package ro.mihai; +import com.twitter.finagle.Http; import com.twitter.finagle.Service; -import com.twitter.finagle.http.Http; +import com.twitter.finagle.builder.ServerBuilder; import com.twitter.util.Future; + + +import org.jboss.netty.handler.codec.http.*; +import org.jboss.netty.handler.codec.http.HttpRequest; +import org.jboss.netty.handler.codec.http.HttpResponse; + import java.net.InetSocketAddress; -import java.net.http.HttpRequest; -import java.net.http.HttpResponse; + public class Main { public static void main(String[] args) { System.out.println("Hello world!"); + Service service = new Service() { public Future apply(HttpRequest request) { - return Future.value( - new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK)); + DefaultHttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK); + return Future.value(response); } }; ServerBuilder.safeBuild(service, ServerBuilder.get() .codec(Http()) .name("HttpServer") - .bindTo(new InetSocketAddress("localhost", 5151))); + .bindTo(new InetSocketAddress("localhost", 10000))); } + }