Hi,
I am having an issue with the PersistentChannel. I use the channel for
persistent re-sending of messages to a camel endpoint.
I basically send the message through the channel to an actor, have this
actor use ask to send the request to a camel producer actor, and handle the
response using map on the future I get back from ask. I confirm the message
once I receive the response.
In my unit tests this works fine for the first run without a journal
directory. The second run is also fine, I set the akka loglevel to debug,
both log outputs are pretty much equal. The third run, however, will fail
as messages from the second run are now redelivered.
I use PersistentChannels in other parts as well, and have no issues there,
so I suspect this might have to do with the ask pattern somehow.
In pseudish code, this is a simple version of what I do:
ConfirmablePersistent msg = ...
Future future = Patterns.ask(producer, msg.payload(), timeout);
future.map(... apply(response) {
msg.confirm();
return response;
}, getContext().dispatcher());
Mostly I tested this with 2.3.0-RC4, but I also gave it a run with the
newly released 2.3.0.
I will try to write a simple test in the akka codebase to reproduce this,
but perhaps someone already has some helpful ideas in the meantime?
Cheers,
Michael
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/groups/opt_out.
