camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: usage of multicast
Date Wed, 22 Apr 2009 08:20:10 GMT
Hi

You can also use .convertBodyTo(String.class) instead of the JMS queue.
It will convert the payload from stream based into a String that
safely can be read multiple times.
You can also use byte[].class if you want to keep it as byte based.


On Wed, Apr 22, 2009 at 10:15 AM, G.J. van de Streek <streek@avisi.nl> wrote:
>
> I noticed, that if I insert a queue in the route and go from there, that it
> works:
>
>    public void configure() {
>
>        from("timer://foo?fixedRate=true&delay=0&period=60000")
>                .to("http://avisi.nl/integration/agents")
>                .to("activemq:example.B");
>
>        from("activemq:example.B")
>                .multicast()
>                .to("direct:splitAgentsFile", "direct:saveAgentsFile")
>                ;
>
>        from("direct:saveAgentsFile")
>                .setHeader(FileComponent.HEADER_FILE_NAME, "agents.xml")
>
> .to("file:///Users/streekgj/Desktop/filestore/?append=false")
>                ;
>
>        from("direct:splitAgentsFile")
>                .splitter(new XPathExpression("/agents/agent"))
>                .to("activemq:example.A")
>                ;
> --
> View this message in context: http://www.nabble.com/usage-of-multicast-tp23163812p23171791.html
> Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
>
>



-- 
Claus Ibsen
Apache Camel Committer

Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
Apache Camel Reference Card:
http://refcardz.dzone.com/refcardz/enterprise-integration

Mime
View raw message