|
Akka/Scala example source code file (OnRouteResponseTestBase.java)
The OnRouteResponseTestBase.java Akka example source codepackage docs.camel; import akka.actor.*; import akka.testkit.JavaTestKit; public class OnRouteResponseTestBase { public void onRouteResponse(){ //#RouteResponse ActorSystem system = ActorSystem.create("some-system"); Props receiverProps = Props.create(ResponseReceiver.class); final ActorRef receiver = system.actorOf(receiverProps,"responseReceiver"); ActorRef forwardResponse = system.actorOf(Props.create( Forwarder.class, "http://localhost:8080/news/akka", receiver)); // the Forwarder sends out a request to the web page and forwards the response to // the ResponseReceiver forwardResponse.tell("some request", ActorRef.noSender()); //#RouteResponse system.stop(receiver); system.stop(forwardResponse); JavaTestKit.shutdownActorSystem(system); } } Other Akka source code examplesHere is a short list of links related to this Akka OnRouteResponseTestBase.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.