[akka-user] Akka persistentChannel does not delete message from Journal upon confirm

2014-03-11 Thread Manas Kar
Hi, I am very excited about the latest and the biggest feature of Akka2.3.0 that is Persistence. I have posted a question about Akka persistentChannel here.http://stackoverflow.com/questions/22315418/akka-persistentchannel-does-not-delete-message-from-journal-upon-confirm Basically I have

Re: [akka-user] Akka persistentChannel does not delete message from Journal upon confirm

2014-03-11 Thread Martin Krasser
Hi Manas, it should actually be deleted. I modified this example https://github.com/akka/akka/blob/v2.3.0/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/ProcessorChannelExample.scala with your persistent channel config val channel =

[akka-user] ANNOUNCE: rxmon v0.2.1 available

2014-03-11 Thread Eugene Vigdorchik
Hello akka users, I've uploaded version rxmon v0.2.1 for akka 2.3.0 and rxjava 0.17.0 https://github.com/vigdorchik/rxmon and I think akka users might find it helpful. The project is a rather thin layer bridging akka to rxjava-scala and it provides a way to view events coming out of akka

[akka-user] Re: Akka persistentChannel does not delete message from Journal upon confirm

2014-03-11 Thread Manas Kar
Hi Martin, I observed something that kind of contradicts my previous statement. It would be correct to say that the size of journal folder is approximately half the size of SumOf(messages). My messages don't get replayed after the configurable times from the channels. But the journal's are

Re: [akka-user] Query Persistence Journal

2014-03-11 Thread Mike
Hey Martin, thanks for the response. Definitely understand that there's not a requirement that the processor be aware of the View. However if the processors are dynamically created, and I need to have a View for each processor, then the creation of the views needs to be somewhat closely

Re: [akka-user] Query Persistence Journal

2014-03-11 Thread Mike
Sorry. I shouldn't have capitalized View in that last sentence. The Actor I'm using as a view aggregates the events that are published but it does not utilize an Akka Persistence View. On Tuesday, March 11, 2014 2:32:35 PM UTC-5, Mike wrote: Hey Martin, thanks for the response. Definitely