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

BAEL-3863 removed redundant examples

Browse Source
This commit is contained in:
mdabrowski-eu 2020-04-24 20:59:20 +02:00
parent 3e0c3a0d0a
commit ca7d40de8f
2 changed files with 0 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
libraries-rpc/src/main/java/com/baeldung/rpc/finagle/Client.java
View File

@ -1,24 +0,0 @@
package com.baeldung.rpc.finagle;
import com.twitter.finagle.Http;
import com.twitter.finagle.Service;
import com.twitter.finagle.http.Method;
import com.twitter.finagle.http.Request;
import com.twitter.finagle.http.Response;
import com.twitter.util.Await;
import com.twitter.util.Future;
import scala.runtime.BoxedUnit;
public class Client {
public static void main(String[] args) throws Exception {
Service<Request, Response> service = new LogFilter().andThen(Http.newService(":8080"));
Request request = Request.apply(Method.Get(), "/?name=John");
request.host("localhost");
Future<Response> response = service.apply(request);
Await.result(response
.onSuccess(r -> {
System.out.println(r.getContentString());
return BoxedUnit.UNIT;
}));
}
}

15
libraries-rpc/src/main/java/com/baeldung/rpc/finagle/Server.java
View File

@ -1,15 +0,0 @@
package com.baeldung.rpc.finagle;
import com.twitter.finagle.Http;
import com.twitter.finagle.ListeningServer;
import com.twitter.finagle.Service;
import com.twitter.util.Await;
import com.twitter.util.TimeoutException;
public class Server {
public static void main(String[] args) throws TimeoutException, InterruptedException {
Service service = new LogFilter().andThen(new GreetingService());
ListeningServer server = Http.serve(":8080", service);
Await.ready(server);
}
}