Shohei Okumiya

Results 133 comments of 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...