|
Akka/Scala example source code file (ProducerTestBase.java)
The ProducerTestBase.java Akka example source codepackage docs.camel; import java.util.HashMap; import java.util.Map; import akka.testkit.JavaTestKit; import scala.concurrent.Future; import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.actor.Props; import akka.camel.CamelMessage; import akka.pattern.Patterns; public class ProducerTestBase { public void tellJmsProducer() { //#TellProducer ActorSystem system = ActorSystem.create("some-system"); Props props = Props.create(Orders.class); ActorRef producer = system.actorOf(props, "jmsproducer"); producer.tell("<order amount=\"100\" currency=\"PLN\" itemId=\"12345\"/>", ActorRef.noSender()); //#TellProducer JavaTestKit.shutdownActorSystem(system); } @SuppressWarnings("unused") public void askProducer() { //#AskProducer ActorSystem system = ActorSystem.create("some-system"); Props props = Props.create(FirstProducer.class); ActorRef producer = system.actorOf(props,"myproducer"); Future<Object> future = Patterns.ask(producer, "some request", 1000); //#AskProducer system.stop(producer); JavaTestKit.shutdownActorSystem(system); } public void correlate(){ //#Correlate ActorSystem system = ActorSystem.create("some-system"); Props props = Props.create(Orders.class); ActorRef producer = system.actorOf(props,"jmsproducer"); Map<String,Object> headers = new HashMap<String, Object>(); headers.put(CamelMessage.MessageExchangeId(),"123"); producer.tell(new CamelMessage("<order amount=\"100\" currency=\"PLN\" " + "itemId=\"12345\"/>",headers), ActorRef.noSender()); //#Correlate system.stop(producer); JavaTestKit.shutdownActorSystem(system); } } Other Akka source code examplesHere is a short list of links related to this Akka ProducerTestBase.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.