Header goes missing while posting from a periodically polled consumer

[anupamsen]

Hi,

I have a route somewhat like below -

<route id="periodicallyPolledInputQueueHandlerRoute">
  <from
uri="quartz://periodicallyPolledInputQueueHandler?cron=0+0/5+*+*+*+?"/>
  <camel:transacted ref="PROPAGATION_REQUIRED_XL"/>
  <pollEnrich
uri="jms:queue:JMS-Server/periodicallyPolledInputQueue?disableReplyTo=true"/>
  <process ref="periodicallyPolledInputHandler" />
</route>

the periodicallyPolledInputHandler is a Processor that has the following
definition for the process function -

public void process(Exchange exchange) {
  /**
   * Try getting it from the exchange header
   */
  Map headers = new HashMap();

  String username =
(String)exchange.getIn().getHeaders().get(USERNAME_TOKEN);
  String password =
(String)exchange.getIn().getHeaders().get(PASSWORD_TOKEN);
  String ackId = (String)exchange.getIn().getHeaders().get(ACK_ID);

  headers.put(USERNAME_TOKEN, username);
  headers.put(PASSWORD_TOKEN, password);
  headers.put(ACK_ID, ackId);

  String originalConsumer =
(String)exchange.getIn().getHeaders().get(ORIGINAL_CONSUMER_TOKEN);
  if(null != originalConsumer)
  {
    CamelContext context = new DefaultCamelContext();
    context.addComponent("jms", jmsComponent);
    ProducerTemplate template = context.createProducerTemplate();
    template.setDefaultEndpointUri(originalConsumer);
    template.sendBodyAndHeader(originalConsumer, ExchangePattern.InOnly ,
exchange.getIn().getBody(String.class), headers);
  }
}

What I am trying to achieve here is in case the originalConsumer is unable
to reach the respective service it pushes the message to
"JMS-Server/periodicallyPolledInputQueue". Further I am trying to poll the
same queue every 5 minutes and push all the messages to the main consumer
which is represented by a URI stored in the header originalConsumer. 

The issue that I am facing is, the headers set on the process method is not
propagated to the original consumer. I do the following to get the header
tokens - 

String username = (String)exchange.getIn().getHeaders().get(USERNAME_TOKEN);
String password = (String)exchange.getIn().getHeaders().get(PASSWORD_TOKEN);

Even if I print the In headers these are not printed. 

Not sure whats happening here. Help in this regard will be highly
appreciated.

Thanks.




--
View this message in context: 
http://camel.465427.n5.nabble.com/Header-goes-missing-while-posting-from-a-periodically-polled-consumer-tp5719860.html
Sent from the Camel - Users mailing list archive at Nabble.com.