Re: [akka-user] Akka Pattern for a Transactional system with multi-hop requests.

CurioDB implements distributed transactions wit Akka using 2PC and MVCC: https://github.com/stephenmcd/curiodb#transactions On Sunday, 17 July 2016 06:19:14 UTC+10, Love Hasija wrote: > > Appreciate your help. > > This looks great. Would you be able to point me to any possible > implementation

Re: [akka-user] How to know the sequence number of a persisted message?

See PersistentActor.lastSequenceNr, which is the index of the most recently saved (or replayed) message. It's an automatic, built-in part of the system. On Sat, Jul 16, 2016 at 6:41 AM, Guofeng Zhang wrote: > Hi > > To delete messages, I know to know toSequenceNr. But how

Re: [akka-user] problem connecting with TCP for file IO

Thanks for the pointer Konrad .. the Source.maybe worked .. Source.empty used to work earlier :-) On Sunday, July 17, 2016 at 1:41:53 AM UTC+5:30, Konrad Malawski wrote: > > Not very online today, may look into it in more depth tomorrow but at a > glance it seems that you complete the

Re: [akka-user] Akka Pattern for a Transactional system with multi-hop requests.

Appreciate your help. This looks great. Would you be able to point me to any possible implementation on Akka. I am wondering what would be the right design for an Akka implementation in terms of Master/Worker etc. On Saturday, 16 July 2016 23:37:01 UTC+5:30, Dragisa Krsmanovic wrote: > > Looks

Re: [akka-user] problem connecting with TCP for file IO

Not very online today, may look into it in more depth tomorrow but at a glance it seems that you complete the connection too eagerly: instead of Source.empty use Source.maybe (does not immediately send completion; completion == closing the connection). Also, you don't need the GraphDSL, you can

[akka-user] problem connecting with TCP for file IO

Hi - I am using akka-stream 2.4.8 for a use case which used to work properly with earlier version of akka-stream (1.x). It has a client that connects over TCP, streams a csv file to a server. The server receives the stream, parses the csv record and builds some domain object. The issue that

[akka-user] Akka Pattern for a Transactional system with multi-hop requests.

Hi, I am working on solving a problem where there is a business service that is using HBase as a data layer and we are building secondary indexes on the HBase. As you can imagine, a single business service request spawns multiple request to the DB layer within a single logical transaction

[akka-user] Akka Streams Graph Editor tool

Hi, Is there any tool which allows to draw graphs as they were shown in akka docs? I mean that allows using the same blocks and elements. Thanks a lot! Best regards, Sergey -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Akka Streams as an ETL tool?

Akka Streams is an excellent choice for this use case. I would even say that it is the canonical use case for Akka Streams. We have probably not highlighted that enough, yet. Cheers, Patrik tors 14 juli 2016 kl. 13:22 skrev James Matlik : > Using Akka streams for ETL is

[akka-user] How to know the sequence number of a persisted message?

Hi To delete messages, I know to know toSequenceNr. But how could I know the message's sequence number when I persisting a message? Thanks for your help. Guofeng -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: one more issue in migration ..

Just to give some more context on the error that I get .. I get the following when the client side connects to this service .. [INFO] [07/16/2016 14:46:40.274] [front_office-akka.actor.default-dispatcher-2] [akka://front_office/system/IO-TCP/selectors/$a/0] Message [akka.io.Tcp$Write] from

[akka-user] one more issue in migration ..

Hello - I have migrated to akka-streams 2.4.4 from 1.0. The following snippet of code (part of a larger application) used to work properly in 1.0 but fails in 2.4.4 .. def run(): Unit = { implicit val mat = ActorMaterializer() val summarizer = system.actorOf(Props[Summarizer])