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

Reply via email to