camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nick Outram <apa...@nickoutram.name>
Subject PollingConsumer with a seda endpoint
Date Wed, 15 Aug 2007 13:21:46 GMT

I've set up a PollingConsumer against a sesa enpoint:

Endpoint endpoint = camelContext.getEndpoint("seda:message.out.payments");
try {
  pollingConsumer = endpoint.createPollingConsumer();
} catch (Exception e) {
  ...
}

and am sending messages to it using CamelTemplate:

...
try {
  template.send("seda:message.out.payments", new Processor() {
    public void process(Exchange exchange) {
      Message in = exchange.getIn();
      in.setBody("Wibble);
    }
  });
} catch (Exception e) {
...
}

but the messages aren't reaching the PollingConsumer's BlockingQueue
although they are visible on the seda endpoint reference held by the
PollingConsumer.

Is there some trick to setting this up that I'm missing?

-N
-- 
View this message in context: http://www.nabble.com/PollingConsumer-with-a-seda-endpoint-tf4273057s22882.html#a12161911
Sent from the Camel - Users mailing list archive at Nabble.com.


Mime
View raw message