Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of hekonsek@gmail.com designates
 209.85.160.173 as permitted sender)
MIME-Version: 1.0
In-Reply-To: <1339669134990-5714477.post@n5.nabble.com>
References: <1339669134990-5714477.post@n5.nabble.com>
Date: Thu, 14 Jun 2012 13:26:52 +0200
Message-ID: 
 <CALhQg-YA0Suhu4XnuG=SiWWVTU+qHGP348zgrTF4Q70Z_8prBQ@mail.gmail.com>
Subject: Re: copy of Exchange during Multicast
From: Henryk Konsek <hekonsek@gmail.com>
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1

Hi,

> Is there a way to make changes done to the
> header visible in further processing?

Yes. Actually modifications to the headers of the exchanged copied by
multicast are available in the aggregator.

In the example below GroupedExchangeAggregationStrategy will aggregate
two exchanges copied by multicast. And each of the aggregated messages
will got another header set on it (HEADER1 and HEADER2 respectively).

____________________________
CamelContext camelContext = new DefaultCamelContext();
camelContext.addRoutes(new RouteBuilder() {
  @Override
  public void configure() throws Exception {
    from("direct:start").multicast(new GroupedExchangeAggregationStrategy()).
      to("direct:headerModifier1", "direct:headerModifier2").
    end().
    to("log:AGGREGATED");

    from("direct:headerModifier1").process(new Processor() {
      @Override
      public void process(Exchange exchange) throws Exception {
        exchange.getIn().setHeader("KEY1", "VALUE1");
      }
    });

    from("direct:headerModifier2").process(new Processor() {
      @Override
      public void process(Exchange exchange) throws Exception {
        exchange.getIn().setHeader("KEY2", "VALUE2");
      }
    });
  }
});

camelContext.start();
camelContext.createProducerTemplate().sendBody("direct:start", "TestMe!");
____________________________


Kind regards.

-- 
Henryk Konsek
http://henryk-konsek.blogspot.com