Hi Olger,
On 18.04.14 09:25, Olger Warnier wrote:
Hi Patrick,
In a situation with a lot of (Eventsourced)Processors and having a
View to store certain (view) state into a database (or other storage),
You need to take care of the way connections to these storage are
managed, especially when it is used together with cluster sharding.
A single view that is able to proces the events per node (or for
multiple nodes) allows for an easy construction of a CQRS style view
model and allows me to use that same actor to ask for the view data.
(this is how it's done with the Axon framework)
Let's assume that I need this functionality, in what way would you
change the persistence code to support this ?
I'm currently working on view composition using the brand new
akka-stream module. Basic idea is to make views stream producers and to
use the akka-stream DSL to merge message/event streams from several
producers into whatever you need. See also
https://twitter.com/mrt1nz/status/457120534111981569 for a first running
example.
WDYT?
It seems that my other option is to create a distributed publish
subscribe mechanism using channels in order to aggregate the data, but
I prefer to construct it in a way that's inline with the way
persistence works / will work.
Kind regards,
Olger
On Tuesday, April 15, 2014 9:44:51 PM UTC+2, delasoul wrote:
Hello,
problems using a view for multiple processors have been discussed
before, e.g.:
https://groups.google.com/d/msg/akka-user/Tb1Qqh4ZMmo/ssqiBEQ_Eb0J
<https://groups.google.com/d/msg/akka-user/Tb1Qqh4ZMmo/ssqiBEQ_Eb0J>
It would still be a great feature to have though(when you need an
aggregated view on events of multiple processors).
The solution to send the events from views to an aggregator still
leaves me with the question why then use a view at all and not
just send the events from
the processor to the aggregator directly? When using a view in the
"middle" one has to deal again with not sending duplicate messages
to the aggregator when views
replay, persistence(if needed) of the aggregator, losing messages
etc. or am I missing smthg?
michael
On Monday, 14 April 2014 16:42:08 UTC+2, Chanan Braunstein wrote:
Entered: https://github.com/akka/akka/issues/15004
<https://github.com/akka/akka/issues/15004>
--
>>>>>>>>>> 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]
<mailto:[email protected]>.
To post to this group, send email to [email protected]
<mailto:[email protected]>.
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/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/d/optout.
