Cosmetic changes to akka-sample-camel
This commit is contained in:
parent
5bb7811533
commit
177801d8fa
3 changed files with 4 additions and 4 deletions
|
|
@ -9,9 +9,9 @@ import se.scalablesolutions.akka.camel.consume;
|
|||
* @author Martin Krasser
|
||||
*/
|
||||
public interface TypedConsumer1 {
|
||||
@consume("file:data/input/pojo")
|
||||
@consume("file:data/input/typed-actor")
|
||||
public void foo(String body);
|
||||
|
||||
@consume("jetty:http://0.0.0.0:8877/camel/pojo")
|
||||
@consume("jetty:http://0.0.0.0:8877/camel/typed-actor")
|
||||
public String bar(@Body String body, @Header("name") String header);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -20,6 +20,6 @@ http://camel.apache.org/schema/spring/camel-spring.xsd">
|
|||
<akka:camel-context ref="camelContext" />
|
||||
</akka:camel-service>
|
||||
|
||||
<akka:typed-actor id="pojo3" interface="sample.camel.BeanIntf" implementation="sample.camel.BeanImpl" timeout="1000" />
|
||||
<akka:typed-actor id="ta" interface="sample.camel.BeanIntf" implementation="sample.camel.BeanImpl" timeout="1000" />
|
||||
|
||||
</beans>
|
||||
|
|
|
|||
|
|
@ -75,7 +75,7 @@ object StandaloneSpringApplication extends Application {
|
|||
class StandaloneSpringApplicationRoute extends RouteBuilder {
|
||||
def configure = {
|
||||
// routes to typed actor (in ApplicationContextRegistry)
|
||||
from("direct:test3").to("typed-actor:pojo3?method=foo")
|
||||
from("direct:test3").to("typed-actor:ta?method=foo")
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue