|
Akka/Scala example source code file (Consumer3.java)
The Consumer3.java Akka example source codepackage docs.camel; //#Consumer3 import akka.actor.Status; import akka.camel.Ack; import akka.camel.CamelMessage; import akka.camel.javaapi.UntypedConsumerActor; public class Consumer3 extends UntypedConsumerActor{ @Override public boolean autoAck() { return false; } public String getEndpointUri() { return "jms:queue:test"; } public void onReceive(Object message) { if (message instanceof CamelMessage) { getSender().tell(Ack.getInstance(), getSelf()); // on success // .. Exception someException = new Exception("e1"); // on failure getSender().tell(new Status.Failure(someException), getSelf()); } else unhandled(message); } } //#Consumer3 Other Akka source code examplesHere is a short list of links related to this Akka Consumer3.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.