[akka-user] Re: Alpakka connectors issue

2017-09-29 Thread Juan José Vázquez Delgado
I have not tried it but I imagine what you need is a dynamic fan-out. Take a look at this piece of documentation. El miércoles, 27 de septiembre de 2017, 20:29:08 (UTC+2), alberto...@full360.com escribió: > > Hello, I

[akka-user] Re: [akka-http] Tagless Final and ToResponseMarshallable

2017-06-19 Thread Juan José Vázquez Delgado
allers extends CatsMarshallers > > This seems fairly clean and composable, but I'm wondering if there's a way > to prevent having to mix-in FutureOfOptionToResponseMarshaller every time. > > On Tuesday, June 13, 2017 at 10:30:53 PM UTC-7, Juan José Vázquez Delgado > wrote: >> &g

[akka-user] Re: [akka-http] Tagless Final and ToResponseMarshallable

2017-06-13 Thread Juan José Vázquez Delgado
I've faced a similar situation recently working on this example . It's not easy but is definitely feasible. The bottom line is: run your own marshaller. El martes, 13 de junio de 2017, 18:44:01 (UTC+2), Jeff escribió: > > I am trying to learn

[akka-user] Re: [akka-http][akka-streams] Back-pressure uploading big zip files

2016-05-02 Thread Juan José Vázquez Delgado
(UTC+2), Juan José Vázquez Delgado escribió: > > Hi all, > > I'm using akka-http for uploading big zip files (~ 1Gb) containing a bunch > of files to parse. My goal is not to have to temporarily save to disk the > file but reading it on the fly. In order to do t

[akka-user] [akka-http][akka-streams] Back-pressure uploading big zip files

2016-04-28 Thread Juan José Vázquez Delgado
Hi all, I'm using akka-http for uploading big zip files (~ 1Gb) containing a bunch of files to parse. My goal is not to have to temporarily save to disk the file but reading it on the fly. In order to do this, we've written a `ZipInputStreamSource` that builds a `Source` from an

Re: [akka-user] migrating from an earlier version of akka-streams ..

2016-04-27 Thread Juan José Vázquez Delgado
wow, this is not definitely well described in the current documentation. I went through a similar chain of mistakes and misconceptions regarding the semantic of the new groupBy/merge primitives. Thanks Debassigh for bringing this here. Regards, Juanjo. El miércoles, 27 de abril de 2016,

Re: [akka-user] Re: Integration tests with Stubbed Cassandra

2015-10-22 Thread Juan José Vázquez Delgado
and all its topics, 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/d/optout. > -- Juan José Vázquez Delg

[akka-user] Re: Integration tests with Stubbed Cassandra

2015-10-21 Thread Juan José Vázquez Delgado
Hi Anders, You might want to have a look into this [1]. I've used its Cassandra embedded server in several ocassions, e.g. [2]. Hope this helps. [1] https://github.com/Sphonic/sphonic-phantom [2] https://github.com/Tecsisa/reactive-cassandra-phantom El martes, 20 de octubre de 2015, 15:00:59

Re: [akka-user] [akka-cluster] Large cluster or many clusters?

2015-10-14 Thread Juan José Vázquez Delgado
but "one service" :) > > On Sat, Oct 3, 2015 at 7:08 PM, Juan José Vázquez Delgado < > juanjo.vazquez.delg...@tecsisa.com> wrote: > >> This is a question for any of you that have some experience with Akka >> clusters in production. Is it better several domain-c

Re: [akka-user] [akka-streams] How to share extensions?

2015-08-28 Thread Juan José Vázquez Delgado
come up with. :) On Thu, Aug 20, 2015 at 12:54 PM, Juan José Vázquez Delgado juanjo.vazq...@tecsisa.com javascript: wrote: Hi all, In my development shop we're currently having to develop or expand some Akka Streams features in the form of sources, flows and sinks. Some of this building

Re: [akka-user] [akka-streams] How to share extensions?

2015-08-28 Thread Juan José Vázquez Delgado
for inspiration. On Fri, Aug 28, 2015 at 4:27 PM, Juan José Vázquez Delgado juanjo.vazq...@tecsisa.com javascript: wrote: Hi Martynas, thanks for answer. We'll follow this examples and try to adapt our (candidate) extensions. Another question would be if the Akka team would accept PRs directly

[akka-user] [akka-streams] How to share extensions?

2015-08-20 Thread Juan José Vázquez Delgado
Hi all, In my development shop we're currently having to develop or expand some Akka Streams features in the form of sources, flows and sinks. Some of this building blocks could be shared, for instance a source that deals with zipped files containing other zipped files, etc. However, we don't

[akka-user] Re: what is the best practice when implementing DDD following akka-persistence-eventsourcing

2015-06-24 Thread Juan José Vázquez Delgado
Hi Avi, I've found this project [1] particularly useful in order to implement your DDD modeling with the use of Akka. Kudos for Paweł Kaczor. In our implementation, we've changed some backends, as Kafka and Cassandra instead of Event Store, and built some others building blocks, but this

[akka-user] Re: Apache Camel vs Apache Camel + Akka

2015-06-18 Thread Juan José Vázquez Delgado
Hi, We've been dealing with that kind of questions for the last months and eventually ended up thinking that it's better to stick to Akka. It's true that Camel gives you a plethora of connectors and integration patterns right out of the box, but that benefits come with some costs. For

Re: [akka-user] [Akka Streams] At-Least-Once-Delivery behaviour with Kafka and Cassandra

2015-06-15 Thread Juan José Vázquez Delgado
25, 2015 at 8:32 PM, Juan José Vázquez Delgado juanjo.vazq...@tecsisa.com javascript: wrote: Hello everyone, I'm starting with Akka Streams and so far everything is going well. However, I have met with a use case that I don't know how to approach. The scenario is a stream

[akka-user] [Akka Streams] At-Least-Once-Delivery behaviour with Kafka and Cassandra

2015-05-25 Thread Juan José Vázquez Delgado
Hello everyone, I'm starting with Akka Streams and so far everything is going well. However, I have met with a use case that I don't know how to approach. The scenario is a stream with an ActorPublisher as a source that is consuming messages from Kafka and a subscriber as a sink that updates a

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

2014-08-19 Thread Juan José Vázquez Delgado
Hi guys, really interesting thread. However, it follows from this discussion that Akka Persistence is not currently 100% ready for a full CRQS/ES implementation. A little bit frustrating but, to be honest, it's true that it's still an experimental feature. As users, we're assuming this.

[akka-user] Akka Persistence and time series data

2014-07-07 Thread Juan José Vázquez Delgado
Hi guys, We're currently on the verge of refactoring a traditional CRUD based application into a reactive one. We're planning to apply event sourcing with Akka Persitence in order to put in practice CQRS/ES principles. In general terms, we know how to apply this principles when it comes to

[akka-user] Common patterns to deal with master data in Akka systems

2014-04-02 Thread Juan José Vázquez Delgado
Hello all, One of our Akka projects need some kind of master data in order to be initialized properly. Currently, these data reside on a mysql database instance but we're planning to move it to an in-memory datagrid solution. So far so good. My problem comes up when these master data change

Re: [akka-user] Common patterns to deal with master data in Akka systems

2014-04-02 Thread Juan José Vázquez Delgado
on how this master data would change your application. On Wed, Apr 2, 2014 at 12:25 PM, Juan José Vázquez Delgado jvaz...@tecsisa.com javascript: wrote: Hello all, One of our Akka projects need some kind of master data in order to be initialized properly. Currently, these data reside

Re: [akka-user] Common patterns to deal with master data in Akka systems

2014-04-02 Thread Juan José Vázquez Delgado
children depending on it, then stopping them if there is new configuration and creating a new hiearchy do it? On Wed, Apr 2, 2014 at 1:27 PM, Juan José Vázquez Delgado jvaz...@tecsisa.com javascript: wrote: Hi, It'd change the entire Akka system hierarchy. For instance, imagine