diff --git a/src/main/java/org/example/FinagleThriftClient.java b/src/main/java/org/example/FinagleThriftClient.java new file mode 100644 index 0000000..eee22e8 --- /dev/null +++ b/src/main/java/org/example/FinagleThriftClient.java @@ -0,0 +1,30 @@ +package org.example; + +import com.twitter.finagle.ListeningServer; +import com.twitter.finagle.Service; +import com.twitter.finagle.Thrift; +import com.twitter.finagle.builder.ClientBuilder; +import com.twitter.finagle.thrift.ThriftClientRequest; +import com.twitter.util.Await; +import com.twitter.util.Future; +import com.twitter.util.FutureEventListener; + +import java.net.InetSocketAddress; + +public class FinagleThriftClient { + public static void main(String[] args) { + + HelloService.ServiceIface client = Thrift.client().newIface("localhost:8097", HelloService.ServiceIface.class); + + try { + Future response = client.sayHello("Mihai "); + System.out.println(Await.result(response)); + + Future blockResponse = client.blocking_call(); + Await.result(blockResponse); + + } catch (Exception e) { + e.printStackTrace(); + } + } +} diff --git a/src/main/java/org/example/HelloServiceImpl.java b/src/main/java/org/example/HelloServiceImpl.java index 22e6256..6c4b266 100644 --- a/src/main/java/org/example/HelloServiceImpl.java +++ b/src/main/java/org/example/HelloServiceImpl.java @@ -7,7 +7,7 @@ public class HelloServiceImpl implements HelloService.ServiceIface { @Override public Future sayHello(String name) { // Implement the logic for sayHello method - return Future.value("Hello, " + name + "!"); + return Future.value("Hell no, " + name + "!"); } @Override