Hi, > -----Original Message----- > From: Rob Davies [mailto:[EMAIL PROTECTED] > Sent: Friday, January 18, 2008 8:41 AM > > looks like you are creating transacted sessions and not calling commit > - is that you mean to do ?
Where are commits missing? There is one commit after each message creation in the producer and the processor also commits both sessions used for receiving and sending messages. Anything wrong with this? >> Procucer.java >> private void startIteration() throws Exception { >> ... >> session.commit(); >> ... >> } >> >> Processor.java >> public void onMessage(Message message) { >> ... >> sourceSession.commit(); >> ... >> destinationSession.commit(); >> ... >> } Cheers, Jürgen