|
Akka/Scala example source code file (MyEndpoint.java)
The MyEndpoint.java Akka example source codepackage docs.camel; //#Consumer-mina import akka.camel.CamelMessage; import akka.camel.javaapi.UntypedConsumerActor; public class MyEndpoint extends UntypedConsumerActor{ private String uri; public String getEndpointUri() { return uri; } public void onReceive(Object message) throws Exception { if (message instanceof CamelMessage) { /* ... */ } else unhandled(message); } // Extra constructor to change the default uri, // for instance to "jetty:http://localhost:8877/example" public MyEndpoint(String uri) { this.uri = uri; } public MyEndpoint() { this.uri = "mina2:tcp://localhost:6200?textline=true"; } } //#Consumer-mina Other Akka source code examplesHere is a short list of links related to this Akka MyEndpoint.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.