Shohei Okumiya
Shohei Okumiya
I have thought that any pair of `asyncWriteMessages` for the same persistence_id is not invoked at once and then the current implementation is safe since all the `AtomicWrite` is inserted...
It seems that `PersistentActor` writes one or batched events seqentially, but I would like to have more time to get the evidence. https://github.com/akka/akka/blob/master/akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala
You are right and we should serialize events by persistence id. https://groups.google.com/forum/#!topic/akka-user/hi-OlSuO_M0
Created the issue for that topic. https://github.com/okumin/akka-persistence-sql-async/issues/9
Release akka-persistence-sql-async which depends on akka 2.5. https://github.com/okumin/akka-persistence-sql-async/releases/tag/v0.5.0
@jmartinezseven SSL support seems to be implemented. https://github.com/mauricio/postgresql-async/commit/0f9a587ec3a9cd372f0b37f069848201236d2acf Would you try to implement SSL feature and give me PR?
Akka-persistence-sql-async depends on ScalikeJDBC and it has no parameter for `maximumMessageSize`. I would like to modify ScalikeJDBC first and fix the problem.
@rolanddb This looks to be related to #19. If you need SSL support soon, would you give me PR?
Do you have a plan to release this feature? I'm developing a library that consumes msgpack streams(Fluentd's forward requests) but I have noticed that `ChannelBufferInput` doesn't work well on non-blocking...
I applied two changes. I'm waiting for CI to finish. 1. Rebased this branch based on the latest master 2. Added https://github.com/apache/hive/pull/5077/commits/b11e3f88fef2e27934dc8389b8d1e80b6da5fc98 - Now, we can populate correct stats of...