[akka-user] Handle legacy blocking IO (InputStream/OutputStream)

I'm new to akka and have a problem when handling blocking IO. I need to integrate the protobuf library that is reading/writing data using standard java InputStream/OutputStream in a blocking way. In my case I open a network connection using a SocketChannel and create an InputStream and an

[akka-user] Relative router path in configuration file in Akka (Did I miss something?)

I am studying the Akka framework (Java) and building a crawler (which, hopefully, will be open source in the coming months...). I've create some low-level actors which will be responsible to effectively crawl over data sources and return the found data as a message. This actors are running

Re: [akka-user] Akka Persistence: Using Stackable Trait pattern in PersistentActor

Hi Damon, if you use context.become(stateB) in your concrete actor you replace the receive function defined in stackable traits with stateB. I think instead of using context.become you should make wrappedReceive a var and change that to whichever state you want your concrete actor to have. I did

[akka-user] Akka cluster Set up

Hi, I wanted to setup akka cluster on 3 modes such that- one of my node would be starting ActorSystem and would join this to the cluster. Node 2 and Node 3 might join the cluster at any point of time, Once the nodes are up, they must be joined to the cluster. I am trying to visualize

[akka-user] Critical Sharding Issue(Akka persistence 2.3.4)- idExtractor Code Not invoked but shardResolver code invoked

Hi, We are following eventsourcing, DDD/CQRS approach. Single writer at the write side for persisting state. *Note*: Single writers are sharded by ID. We are using Akka-Work-Pull pattern of Typesafe in our application for processing. Jars included for akka persistence are

Re: [akka-user] Critical Sharding Issue(Akka persistence 2.3.4)- idExtractor Code Not invoked but shardResolver code invoked

Hi Prakhyat, I assume you've already tried this, but just for completeness, could you do this: val idExtractor: ShardRegion.IdExtractor = { case created: LedgerCreated ={ println(% IdExtractor : +created.ledgerId.id.toString) (created.ledgerId.id.toString, created) }

[akka-user] Re: Handle legacy blocking IO (InputStream/OutputStream)

(by akka.io, I meant the IO package of akka http://doc.akka.io/docs/akka/2.3.5/scala/io.html, of course...) On Tuesday, September 2, 2014 4:06:56 PM UTC+3, Adam wrote: Hi, I'm not sure how using protobuf forces you to communicate in a blocking manner. I'm also using it but over akka.io,

Re: [akka-user] Re: Facing Sharding issue in akka-contrib_2.10-2.3.4.jar

Hi Martynas, I am using* Cassandra plugin * for *persistance*, For the same below are configuration changes in application.conf for persistance. akka{ persistence { journal.plugin = cassandra-journal } } cassandra-journal { contact-points = [xxx..xxx.xxx] }

[akka-user] Cluster Sharding and akka-persistence-jdbc. Snapshots fail because snapshotSequenceNr isn't incrementing.

Hi All(but mostly Patrik), I'm converting an existing application that previously had a bunch of cluster singletons performing work into something that will do the same thing, but use Cluster Sharding to distribute the work across all the nodes in our cluster. Because of our infrastructure

[akka-user] Cluster aware routers with routees that needs some time to be initialized

Dear Akka users, I want to user group router as a load balancer for an actor deployed on different nodes. The actor needs some time to become usable, let us say 1 minute. Currently I am using registerOnMemberUp pattern to create the actor after the cluster is in UP state. As far as understood

Re: [akka-user] Critical Sharding Issue(Akka persistence 2.3.4)- idExtractor Code Not invoked but shardResolver code invoked

Hi, Tried by adding the default block. I am not getting the logs of that block also. It is not at all invoking the idExtractor. Thanks Asha On Tuesday, 2 September 2014 17:40:04 UTC+5:30, √ wrote: Hi Prakhyat, I assume you've already tried this, but just for completeness, could you do