Re: [akka-user] Re: Akka Camel and Akka Streams

ilto:akka-user+unsubscr...@googlegroups.com>. To post to this group, send email to akka-user@googlegroups.com <mailto:akka-user@googlegroups.com>. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasse

[akka-user] Re: Akka Camel and Akka Streams

Hi Andreas, the replacement for akka-camel is the Streamz project with its Camel DSL for Akka Streams . It allows you to use any Camel component

Re: [akka-user] Akka Persistence with Multi-Clusters

utomatic, i.e. CRDTs, and then I wonder what the vector clocks adds? -- Martin Krasser blog:http://krasserm.github.io code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current

Re: [akka-user] Akka Persistence with Multi-Clusters

On 31.01.16 17:48, Roland Kuhn wrote: Hi Martin! 31 jan 2016 kl. 15:36 skrev 'Martin Krasser' via Akka User List <akka-user@googlegroups.com <mailto:akka-user@googlegroups.com>>: Hi Roland, a few clarifications/additions inline ... On 31.01.16 10:17, Roland Kuhn wro

Re: [akka-user] Akka Persistence with Multi-Clusters

of efforts idea! Greetings Odd On Sun, Jan 31, 2016 at 3:36 PM, 'Martin Krasser' via Akka User List <akka-user@googlegroups.com <mailto:akka-user@googlegroups.com>> wrote: Hi Roland, a few clarifications/additions inline ... On 31.01.16 10:17, Roland Kuhn wrote:

[akka-user] HTTP(S) tunnel for akka-remote

remote? Are there other HTTP(S) tunneling alternatives you can recommend? Thanks, Martin -- Martin Krasser blog:http://krasserm.github.io code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/doc

[akka-user] Make unstash() public

using stash()/unstashAll(). Thanks, Martin -- Martin Krasser blog:http://krasserm.github.io code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html

Re: [akka-user] Akka Persistence on the Query Side: The Conclusion

* /Akka Tech Lead/ Typesafe http://typesafe.com/ – Reactive apps on the JVM. twitter: @rolandkuhn http://twitter.com/#%21/rolandkuhn -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io

Re: [akka-user] Unresponsive akka persistence Cassandra journal causes View to stop polling

...@googlegroups.com mailto:akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser

[akka-user] Re: Akka Persistence on the Query Side: The Conclusion

perspective and look forward to your feedback on how well this helps Akka users implement the Q in CQRS. Regards, *Dr. Roland Kuhn* /Akka Tech Lead/ Typesafe http://typesafe.com/ – Reactive apps on the JVM. twitter: @rolandkuhn http://twitter.com/#%21/rolandkuhn -- Martin Krasser blog:http

Re: [akka-user] Akka Persistence on the Query Side: The Conclusion

, Roland 28 aug 2014 kl. 11:12 skrev ahjohannessen ahjohannes...@gmail.com mailto:ahjohannes...@gmail.com: Hi Martin, On Thursday, August 28, 2014 8:01:43 AM UTC+1, Martin Krasser wrote: In your summary, the only query command type pre-defined in akka-persistence is QueryByPersistenceId

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

. It's probably too early for best practices but knowing what may work well (or not) in real-world applications is invaluable. Of course, thanks to the others in the Akka team and Greg as well. Cheers, Ashley. On Wednesday, 27 August 2014 12:31:15 UTC+8, Martin Krasser wrote: Whether to go

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

-term event storage (and full event history replay). WDYT? W dniu wtorek, 26 sierpnia 2014 15:28:47 UTC+2 użytkownik Martin Krasser napisał: Hi Andrzej, On 26.08.14 09:15, Andrzej Dębski wrote: Hello Lately I have been reading about a possibility of using Apache Kafka

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

On 26.08.14 19:56, Greg Young wrote: I'm curious how you would model say bank accounts with only a few hundred actors can you go into a bit of detail persistent-actor : bank-account = 1:n (instead of 1:1) On Tuesday, August 26, 2014, Martin Krasser krass...@googlemail.com mailto:krass

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

See my eventsourced example(s), that I published 1-2 years ago, others are closed source On 26.08.14 20:06, Greg Young wrote: Love to see an example On Tuesday, August 26, 2014, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: On 26.08.14 19:56, Greg Young

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

elaborate. On Tue, Aug 26, 2014 at 2:08 PM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: See my eventsourced example(s), that I published 1-2 years ago, others are closed source On 26.08.14 20:06, Greg Young wrote: Love to see an example

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

whole series of hokey problems trying to do from here forward type things (imagine a new feature that relies on a 6 month moving average) On Tue, Aug 26, 2014 at 2:15 PM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: On 26.08.14 20:12, Greg Young wrote

Re: [akka-user] Apache Kafka as journal - retention times/PersistentView and partitions

? That would be interesting feature - certainly would make akka + Kafka combination viable for more use cases. W dniu wtorek, 26 sierpnia 2014 19:44:05 UTC+2 użytkownik Martin Krasser napisał: On 26.08.14 16:44, Andrzej Dębski wrote: My mind must have filtered out the possibility of making

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

Am 20.08.2014 13:33 schrieb Roland Kuhn goo...@rkuhn.info: 20 aug 2014 kl. 10:43 skrev Martin Krasser krass...@googlemail.com: On 20.08.14 10:16, Roland Kuhn wrote: 19 aug 2014 kl. 18:59 skrev Ashley Aitken amait...@gmail.com: On Tuesday, 19 August 2014 21:14:17 UTC+8, rkuhn wrote: 18

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

to akka-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

On 19.08.14 10:00, Patrik Nordwall wrote: On Tue, Aug 19, 2014 at 8:51 AM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: Hi Ashley, thanks for bringing up these questions. Here are some general comments: as you already mentioned

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

On 19.08.14 11:28, Ashley Aitken wrote: On Tuesday, 19 August 2014 16:53:46 UTC+8, Martin Krasser wrote: journal - akka actor(s) - read model datastore when I can do this much more efficiently via journal - spark - read model datastore directly, for example I am

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

On 19.08.14 13:00, Roland Kuhn wrote: 19 aug 2014 kl. 11:28 skrev Ashley Aitken amait...@gmail.com mailto:amait...@gmail.com: On Tuesday, 19 August 2014 16:53:46 UTC+8, Martin Krasser wrote: journal - akka actor(s) - read model datastore when I can do this much more

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

On 19.08.14 13:40, Patrik Nordwall wrote: On Tue, Aug 19, 2014 at 1:35 PM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: On 19.08.14 13:00, Roland Kuhn wrote: 19 aug 2014 kl. 11:28 skrev Ashley Aitken amait...@gmail.com mailto:amait

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

On 19.08.14 14:37, Roland Kuhn wrote: 19 aug 2014 kl. 13:49 skrev Patrik Nordwall patrik.nordw...@gmail.com mailto:patrik.nordw...@gmail.com: On Tue, Aug 19, 2014 at 1:46 PM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: On 19.08.14 13:40, Patrik

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

On 19.08.14 17:41, Ashley Aitken wrote: On Tuesday, 19 August 2014 19:33:55 UTC+8, Martin Krasser wrote: If so, it sounds like a great solution but why would that require an extension to the Akka Persistence design/API? Because transformed/joined/... event streams in backend

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

/...) these events. or is this all done via the plugin for PersistentViews? (I guess it has to be like this, otherwise using only one backend store cannot be supported?) thanks, michael On Tuesday, 19 August 2014 17:48:16 UTC+2, Martin Krasser wrote: On 19.08.14 17:41, Ashley Aitken wrote

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

it in event store but most don't use it. Can you please share any pointers that describe how causal consistency is supported/implemented by event store? On Tuesday, August 19, 2014 11:08:14 AM UTC-4, Martin Krasser wrote: On 19.08.14 16:27, Greg Young wrote: I am not responding

Re: [akka-user] Re: ANNOUNCE: Akka 2.3.5 Released

/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] Akka Persistence: LogProducer and LogConsumer?

#journal-topics developed by Martin Krasser, it adresses some of the points raised actually. Yes, I am aware of that (and thanks to Martin!) but Kafka (please correct me if I am wrong) doesn't have the ability to create projections. Perhaps for now we can just manually post events

Re: [akka-user] akka-persistence cassandra journal plugin api

@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

easier implemented. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

email to akka-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http

Re: [akka-user] Kafka journal

There's now a first release of the Kafka journal. Details at https://github.com/krasserm/akka-persistence-kafka Am Sonntag, 13. Juli 2014 16:19:55 UTC+2 schrieb Martin Krasser: On 13.07.14 16:03, Richard Rodseth wrote: Thanks for the detailed reply. I might have been forgetting

Re: [akka-user] Kafka journal

On 14.07.14 16:46, Jonas Bonér wrote: Great work Martin. Thanks! On Mon, Jul 14, 2014 at 4:36 PM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: There's now a first release of the Kafka journal. Details at https://github.com/krasserm/akka

Re: [akka-user] Kafka journal

Thanks Heiko, really hope to get some user feedback ... On 14.07.14 17:04, Heiko Seeberger wrote: Fantastic! Great work, Martin. Keep it coming! Heiko On 14 Jul 2014, at 16:36, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: There's now a first release

Re: [akka-user] Kafka journal

to a Cassandra or MongoDB cluster, for example. Hope that clarifies things a bit. Cheers, Martin On 12.07.14 15:35, Richard Rodseth wrote: I saw a tweet from Martin Krasser that he was working on an Akka Persistence journal plug-in for Kafka. This puzzled me a bit since Kafka messages are durable

Re: [akka-user] Kafka journal

Kafka supports large log entries. On Sun, Jul 13, 2014 at 12:51 AM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: Hi Richard, when using the Kafka journal with default/typical retention times, your application is responsible for storing snapshots

Re: [akka-user] serialization and long-term event sourcing with akka persistence

? Was thinking it might be less work if you want to have e.g. maps after derserialization? (maps not supported in protobuf) /Per On Thursday, 8 May 2014 09:47:46 UTC+1, Martin Krasser wrote: On 08.05.14 10:43, Tim Pigden wrote: Hi I've found a new thing to worry about

Re: [akka-user] Unable to acquire lock on levelDB when persistence is deployed in a akka cluster

. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter:http://twitter.com/mrt1nz -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http

Re: [akka-user] How can the sender know that a message has been delivered (confirmed) by a channel?

On 09.05.14 09:25, Roland Kuhn wrote: 9 maj 2014 kl. 09:08 skrev Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com: On 09.05.14 08:41, Roland Kuhn wrote: Hi Martin, 9 maj 2014 kl. 08:05 skrev Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com

Re: [akka-user] Re: Pulling Pattern vs Durable Mailboxes

On 07.05.14 17:10, Matthew Howard wrote: On Wednesday, May 7, 2014 12:57:23 AM UTC-4, Martin Krasser wrote: Please not that the primary use case for persistent channels is to deal with slow and/or temporarily available consumers/destinations. It is not optimized for high

Re: [akka-user] [akka-persistence-2.3.2] Can the LevelDB support multiple (unique) processors writing to the journal

@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http

Re: [akka-user] [akka-persistence-2.3.2] Can the LevelDB support multiple (unique) processors writing to the journal

, May 8, 2014 2:28:07 PM UTC+8, Martin Krasser wrote: On 08.05.14 08:23, Raymond Tay wrote: Hi all, Was wondering whether LevelDB supports multiple yet distinct processors into the same journal within the same `ActorSystem` ? Sure, they only must have different processorIds

Re: [akka-user] Re: Pulling Pattern vs Durable Mailboxes

. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] Views for many entities?

On 06.05.14 08:18, Ashley Aitken wrote: Hi Martin, Thank you for your response to my questions. On Tuesday, 6 May 2014 13:13:46 UTC+8, Martin Krasser wrote: Finally, I believe I would like to track all the events that get added to the entire journal (treating it like a combined log

Re: [akka-user] Re: Reactive applications with CQRS and Akka Persistence?

/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] Re: Reactive applications with CQRS and Akka Persistence?

On 06.05.14 09:31, Ashley Aitken wrote: On Tuesday, 6 May 2014 15:18:29 UTC+8, Martin Krasser wrote: The availability of (new) events in the journal is also an event. Whether a view is actively notified about their availability (= push) or if the view tries to find out itself

Re: [akka-user] Re: Reactive applications with CQRS and Akka Persistence?

On 06.05.14 19:10, Ashley Aitken wrote: Thanks Martin. On Tuesday, 6 May 2014 15:53:28 UTC+8, Martin Krasser wrote: On 06.05.14 09:31, Ashley Aitken wrote: Reactive I take to mean push, the events are driving action in the system, from GUI to GUI. From a user's (= API

Re: [akka-user] Views for many entities?

On 06.05.14 18:21, Ashley Aitken wrote: Thanks again Martin. On Tuesday, 6 May 2014 14:37:48 UTC+8, Martin Krasser wrote: Good so I am on the write track. I am confused a little about the Views keeping stage in memory and with snapshots. What state would this be? Surely

Re: [akka-user] akka-persistence Processor preStart override problems

to make a pull request with the changes you'd like to see in the docs? Thanks, Martin On Monday, May 5, 2014 11:40:59 PM UTC-6, Martin Krasser wrote: On 06.05.14 04:26, Vaughn Vernon wrote: When I override preStart in any way other than invoking super.preStart() my actor is unable

Re: [akka-user] Re: Pulling Pattern vs Durable Mailboxes

On 06.05.14 21:13, Matthew Howard wrote: On Tuesday, May 6, 2014 2:06:16 AM UTC-4, Martin Krasser wrote: You may be interested in this pull request https://github.com/akka/akka/pull/15036 that enables reading from akka-persistence journals via reactive-stream

Re: [akka-user] Cassandra Journal v2.0.3?

-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com

Re: [akka-user] akka-persistence Processor preStart override problems

...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com

Re: [akka-user] How can the sender know that a message has been delivered (confirmed) by a channel?

at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ

Re: [akka-user] How can the sender know that a message has been delivered (confirmed) by a channel?

On 04.05.14 10:07, Heiko Seeberger wrote: On Sun, May 4, 2014 at 9:55 AM, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: Hi Heiko, On 03.05.14 06:58, Heiko Seeberger wrote: Hi, A short-lived actor A should send a result message to some

Re: [akka-user] How can the sender know that a message has been delivered (confirmed) by a channel?

Maybe a confirm(reply: Any) method would make sense, where reply is sent to the sender of the Persistent message. This would also allow for some internal optimizations. On 04.05.14 10:18, Martin Krasser wrote: On 04.05.14 10:07, Heiko Seeberger wrote: On Sun, May 4, 2014 at 9:55 AM, Martin

Re: [akka-user] How can the sender know that a message has been delivered (confirmed) by a channel?

, Martin Krasser krass...@googlemail.com mailto:krass...@googlemail.com wrote: Maybe a confirm(reply: Any) method would make sense, where reply is sent to the sender of the Persistent message. This would also allow for some internal optimizations. On 04.05.14 10:18, Martin

Re: [akka-user] akka-persistence handling journal failures with Views

(ticket created https://github.com/akka/akka/issues/15094). Only after I've overridden the onReplayFailure have I noticed them occurring. Best, -- Jacek On Tuesday, April 29, 2014 4:46:54 PM UTC+2, Martin Krasser wrote: On 29.04.14 15:00, Jacek Dąbrowski wrote: Hi Martin

Re: [akka-user] Recovery following node failure

...@googlegroups.com mailto:akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin

Re: [akka-user] Has anyone tried akka-persistence on Android?

On 28.04.14 17:17, Martin Krasser wrote: On 28.04.14 16:30, Oscar Vargas Torres wrote: Hello Martin. Thanks a lot for helping us. Following your suggestion gives this error: https://github.com/Optrak/akkaPersistenceWithAndroid/blob/master/errorMsg6.txt Line 13: 04-28 08:54:25.036 12011

Re: [akka-user] akka-persistence handling journal failures with Views

at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http

Re: [akka-user] akka-persistence handling journal failures with Views

On 29.04.14 07:22, Martin Krasser wrote: Hi Jacek, you can achieve that by overriding the methods onReplaySuccess and onReplayFailure in akka.persistence.View. Only problem is that their visibility is private[persistence] in the latest release, so you'd need to place your implementation

Re: [akka-user] Has anyone tried akka-persistence on Android?

#L32 pfn: there you go pfn: *leveldb won't even work on android* pfn: there is no system property sun.arch.data.model pfn: so it returns null, unboxing to int = nullpointer So what are the alternatives? -- Martin Krasser blog:http://krasserm.blogspot.com code:http

Re: [akka-user] Has anyone tried akka-persistence on Android?

mailto:akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog

Re: [akka-user] EventSourced/Akka Persistence Transactionally Saving Multiple Events

options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html

[akka-user] Re: Reliable event stream composition with cluster sharding

Hi Hannes, consider using channels with an aggregating processor as destination (or, more generally, an actor that updates a database). If the source processors are eventsourced processors make sure to setup reliable event

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

wrong because of which only I see this and no-one else seems to be complaining about. ...Manas On Friday, March 21, 2014 3:49:17 AM UTC-4, Martin Krasser wrote: On 19.03.14 15:38, Manas Kar wrote: Hi Martin, I have a process that is running since last Sunday evening using

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

. Could that be playing some role? No. Thanks Manas On Wednesday, March 12, 2014 1:09:38 PM UTC-4, Manas Kar wrote: Thanks Martin. That explains what I am seeing. On Wednesday, March 12, 2014 12:15:15 PM UTC-4, Martin Krasser wrote: On 11.03.14 19:22, Manas Kar

Re: [akka-user] Re: Possible bug in akka-persistence

this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check

Re: [akka-user] akka persistence leveldb journal size issue

this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs

Re: [akka-user] Processor's last-processed-id tracking and exactly-once message delivery

mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read

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

@googlegroups.com mailto:akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz

Re: [akka-user] Query Persistence Journal

On 07.03.14 10:27, delasoul wrote: Hello Martin, On Friday, 7 March 2014 08:39:27 UTC+1, Martin Krasser wrote: If ordering is not important for your use case, just setup n views and send their received messages to an aggregator for example. Please note that in this case

Re: [akka-user] PersistentChannel Redelivers confirmed messages on restart

. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io

Re: [akka-user] PersistentChannel Redelivers confirmed messages on restart

. Very puzzling. Cheers, Michael Am Donnerstag, 6. März 2014 09:04:41 UTC+1 schrieb Martin Krasser: Hi Michael, confirm() is an asynchronous operation. If your test ends before the confirmation is written to the journal or the confirmation is written concurrently to a follow-up

Re: [akka-user] Query Persistence Journal

, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://akka.io/faq/ Search the archives: https

Re: [akka-user] Event Sourcing and Versioning

https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://akka.io/faq/ Search the archives: https

Re: [akka-user] persistent views/cluster sharding

. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://akka.io/faq/ Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] Re: Akka persistence - retrieve processor id from journal

/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://akka.io/faq/ Search the archives: https://groups.google.com/group/akka-user --- You

Re: [akka-user] Questions regarding Akka persistence module

an event to M1 to increase the balance (in case an order doesn't exist, no event is ever persisted). In such a use case, both M1 and M2 shall be Eventsourced processors, and I'd like them to work together. Does this make any sense? -- Martin Krasser blog:http://krasserm.blogspot.com code

Re: [akka-user] Questions regarding Akka persistence module

a ticket and we will investigate it. The least we can do is to document the limitation (well, it's already documented in the ScalaDoc) and how to work around it. /Patrik On Thursday, February 20, 2014 6:17:46 PM UTC+8, Martin Krasser wrote: Why don't you let M2 handle createOrder

Re: [akka-user] persistence.channel question

for the actorSelection to send it a Deliver message. Thanks in advance for your answers, michael On Thursday, 6 February 2014 07:43:12 UTC+1, Martin Krasser wrote: Hi Brian, On 06.02.14 01:01, Brian McDevitt wrote: When using a Channel actor from the persistence package

Re: [akka-user] No CurrentState when preStart is overriden

Am 31.01.2014 15:31 schrieb Vadim Bobrov vadimbob...@gmail.com: On Friday, January 31, 2014 2:02:34 AM UTC-5, Martin Krasser wrote: On 30.01.14 23:22, Vadim Bobrov wrote: That is what I meant, yes. Leaving messages on the JMS queue wouldn't work for me because I have other actors (like

Re: [akka-user] No CurrentState when preStart is overriden

this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check

Re: [akka-user] No CurrentState when preStart is overriden

-recovered processors on both start and re-start is critical for most use cases, especially for consistent recovery a network of processors. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http

Re: [akka-user] No CurrentState when preStart is overriden

an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com

Re: [akka-user] No CurrentState when preStart is overriden

this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check

Re: [akka-user] Re: akka persistence use-case: a node fails and never comes back

internally writes Persistent event messages. thanks in advance, michael On Monday, 20 January 2014 15:18:29 UTC+1, Martin Krasser wrote: Hi Vatel, On 20.01.14 13:40, vate...@gmail.com javascript: wrote: Endre, for example: SenderActor at NodeA is ready to send Message1 (maybe

Re: [akka-user] How to not loose events -- looking for pattern

it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http

Re: [akka-user] Persistent messages out-of-order when sent via channel

a message to the database, it can confirm message delivery (which asynchronously removes it from the journal - preventing unlimited journal growth). Alternatives: - write to the database directly (if fast enough) - use a 3rd-party persistent messaging server -- Martin Krasser blog

Re: [akka-user] Persistent messages out-of-order when sent via channel

sender that the message has been successfully persisted. If the sender gets a reply from handling a PersistenceFailure message or no reply (timeout), it has to resend the Persistent message. There are numerous ways (impl options) for resending messages. Using a channel is only one. -- Martin

Re: [akka-user] leveldb journal growth

. With this new implementation I now also see a shrink of LevelDB. I'll include that improvement into 2.3-RC1. Thanks Vadim -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs

Re: [akka-user] Persistent messages out-of-order when sent via channel

/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://akka.io/faq

Re: [akka-user] leveldb journal growth

is a bit surprising. I did read about leveldb compactions but coouldn't find anything that would have explained the growth -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http

Re: [akka-user] Re: resolve of path sequence failed

, visit https://groups.google.com/groups/opt_out. -- Martin Krasser blog:http://krasserm.blogspot.com code:http://github.com/krasserm twitter: http://twitter.com/mrt1nz -- Read the docs: http://akka.io/docs/ Check the FAQ: http://akka.io/faq/ Search the archives: https