The main reasons for your problems is that your lightweight components
do not correctly
handle the exchanges.
First, i would encourage you to use servicemix-bean instead, because
servicemix-lwcontainer
is deprecated.
Second, when dealing with InOnly exchanges, the exchange will come
back to the endpoint
with a DONE status, so you need to ignore them. Else, as you can see
in your log, you end up with
more and more messages in the bus, because each component will send
two messages instead of
one. Also don't forget to set the DONE status and send back the
exchange when your component
acts as a provider.
The code of your components should look like:
public void processExchange(MessageExchange exchange) {
if (exchange.getStatus() == ExchagneStatus.DONE) {
// Ignore the exchanges that come back in a done status
// these are the ones we created and sent
return;
}
// we receive an exchange, so create a new exchange, populate it
// and send it, then set the DONE status on
InOnly newExchange = ...
channel.send(newExchange);
exchange.setStatus(ExchangeStatus.DONE);
channel.send(exchange);
}
On Wed, Feb 27, 2008 at 5:16 PM, sachin2008 <[EMAIL PROTECTED]> wrote:
>
> I am attaching the log.Can u please look into it
>
> http://www.nabble.com/file/p15716668/servicemix.log servicemix.log
>
>
>
> gnodet wrote:
> >
> > It should be set automatically.
> > Could you paste the log at debug level ?
> >
> > On Wed, Feb 27, 2008 at 4:57 PM, sachin2008 <[EMAIL PROTECTED]> wrote:
> >>
> >> Can you please tell me how to set the global
> >> variable"org.apache.servicemix.correlationId".
> >>
> >>
> >>
> >> gnodet wrote:
> >> >
> >> > If you add the following lines in your components, you should see
> >> them, as
> >> > the
> >> > exception happens when aggregating those messages later.
> >> >
> >> > for (Object key : exchange.getPropertyNames()) {
> >> > System.out.println(key + ": " + exchange.getProperty((String)
> >> key));
> >> > }
> >> >
> >> > If the "org.apache.servicemix.correlationId" is not listed, there is a
> >> > problem ...
> >> >
> >> > On Wed, Feb 27, 2008 at 3:58 PM, sachin2008 <[EMAIL PROTECTED]>
> >> wrote:
> >> >>
> >> >> I am not able to trace that one
> >> >>
> >> >> I am getting the same exception continuously. Whether there is any
> >> way
> >> >> to
> >> >> set that global variable anywhere else.
> >> >>
> >> >>
> >> >>
> >> > --
> >> > Cheers,
> >> > Guillaume Nodet
> >> > ------------------------
> >> > Blog: http://gnodet.blogspot.com/
> >> >
> >> >
> >>
> >> --
> >>
> >>
> >> View this message in context:
> >>
> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15716224.html
> >> Sent from the ServiceMix - User mailing list archive at Nabble.com.
> >>
> >>
> >
> >
> >
> > --
> > Cheers,
> > Guillaume Nodet
> > ------------------------
> > Blog: http://gnodet.blogspot.com/
> >
> >
>
> --
> View this message in context:
> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15716668.html
>
>
> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>
>
--
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/
