|
Akka/Scala example source code file (Transformer.java)
The Transformer.java Akka example source codepackage docs.camel; //#TransformOutgoingMessage import akka.camel.CamelMessage; import akka.camel.javaapi.UntypedProducerActor; import akka.dispatch.Mapper; import akka.japi.Function; public class Transformer extends UntypedProducerActor{ private String uri; public Transformer(String uri) { this.uri = uri; } public String getEndpointUri() { return uri; } private CamelMessage upperCase(CamelMessage msg) { return msg.mapBody(new Mapper<String,String>() { @Override public String apply(String body) { return body.toUpperCase(); } }); } @Override public Object onTransformOutgoingMessage(Object message) { if(message instanceof CamelMessage) { CamelMessage camelMessage = (CamelMessage) message; return upperCase(camelMessage); } else { return message; } } } //#TransformOutgoingMessage Other Akka source code examplesHere is a short list of links related to this Akka Transformer.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.