akka-user@googlegroups.com discussions for October 2015

22	[akka-user] How do I attach multiple subscribers to a stream using fanoutPublisher, actorSubscriber and FlowGraph.partial?

I'm cutting my teeth on Akka streams, building the quintessential Twitter streaming client. What I'm trying to do is some processing on the tweet stream and then based on the result, divide the ...

Abhijit Sarkar
Oct 4, 2015 at 10:09 am
Oct 7, 2015 at 8:35 am

16	[akka-user] Akka remote communication roadmap?

Hi, I created a similar post some time ago but the circumstances were a bit different, the project I'm working at the moment has the requirement of processing messages within 5ms, and I chose Akka ...

Guido Medina
Oct 14, 2015 at 9:22 am
Oct 20, 2015 at 12:00 pm

13	[akka-user] is there a way to know when really an actor has stopped

I create a named actor, stop it and recreate it with the same name. Because stop is async, I end up with exceptions like akka.actor.InvalidActorNameException: actor name [databaseServer] is not ...

Kostas kougios
Oct 2, 2015 at 2:59 pm
Oct 12, 2015 at 8:51 pm

11	[akka-user] Modeling synchronous startup behavior

I had seen a previous post that didn't really seem to come to any definite conclusion about this subject. I have some synchronous behavior I need to accomplish during my actor's construction, but the ...

Rich Henry
Oct 19, 2015 at 1:21 pm
Oct 25, 2015 at 11:39 am

10	[akka-user] Capturing the message that killed an actor

I'm trying to respond to the sender of a message that killed my actor. I know I get the message if in preRestart if I chose to restart, but if my supervisorStrategy decided to stop (because of max ...

Arne Claassen
Oct 15, 2015 at 5:38 pm
Oct 20, 2015 at 9:23 am

9	[akka-user] My feedback for akka-typed

Hi there! We at Tiny Lab Productions are using Scala+Akka for our game servers. Recently I whined my ex-colleague and your current colleague at Akka Martynas Mickevičius about how untyped actor refs ...

Artūras Šlajus
Oct 25, 2015 at 1:02 pm
Oct 27, 2015 at 5:33 pm

9	[akka-user] Fwd: Proposed major simplification of the Akka Streams FlowGraph APIs

Hi everyone, I'm proposing the following (breaking) changes to the FlowGraph-related APIs, in order to make it consistent, with a smaller surface area and with more obvious demarcation of power-level ...

Viktor Klang
Oct 17, 2015 at 8:57 pm
Oct 20, 2015 at 9:29 am

8	[akka-user] How to get the count of messages from stream?

Hello, I'm having an akka stream like, kafkasource ~ transformer ~ Sink(Subscriber) This is the subscriber class I'm using: class Subscriber extends ActorSubscriber { import context.dispatcher ...

Jeeva K
Oct 22, 2015 at 5:24 pm
Oct 24, 2015 at 3:10 pm

8	[akka-user] How is Initial Demand Generated in this Example?

I'm cutting my teeth on Akka streams and did a fibonacci publisher-subscriber example as follows. However, I don't quite understand yet how the demand is initially generated and what relation it has ...

Abhijit Sarkar
Oct 5, 2015 at 5:22 am
Oct 15, 2015 at 2:39 am

8	[akka-user] Explaining AKKA Thread Pool Execturor Config parameters

Hi, As I understood that the fork-join-executor is the default dispatcher when non is provided when creating the actor system Can someone explain me the following: 1. fork-join-executor { 2. # Min ...

Maatary Okouya
Oct 11, 2015 at 7:28 pm
Oct 12, 2015 at 10:14 pm

7	[akka-user] Cleaning up on Flow completion

*TL;DR -- Is there any way to provide an individual Flow component with logic to execute on Graph completion?* I'm trying to wrap an existing API that is used like this: obj.handleContext(c1) ...

Rich Henry
Oct 27, 2015 at 6:49 pm
Oct 28, 2015 at 5:02 pm

7	[akka-user] Why is aroundReceive protected[akka]?

Hi, looking at akka-streams ActorPublisher recently, I found the approach to implement actor 'base-behavior' using aroundReceive quite elegant and much more natural than partial function chaining. Is ...

Jan Algermissen
Oct 18, 2015 at 10:08 pm
Oct 21, 2015 at 2:05 pm

7	[akka-user] Marshalling FormData to multi-part mime with one field per part

AWS/S3 HTTP Post with a policy requires an HTTP post with multipart-mime -- one part for the file and one part, each, for various form parameters. When I use akka.http and attempt to marshal FormData ...

Eric Swenson
Oct 12, 2015 at 4:18 am
Oct 15, 2015 at 8:10 pm

7	[akka-user] Access to variable in a UntypedActor causes a permanent stall on the 55th onReceive

Hi, I have a subclass of an UntypedActor that I use a Future to access. It works for hundreds of accesses then on the same nth message stalls at the same line in a method inside the Actor each time ...

Olddave
Oct 1, 2015 at 8:48 am
Oct 14, 2015 at 8:18 am

6	[akka-user] Akka-Stream not truncating and failing

Hello there, I am new to Akka-Stream and working on a use case where I need to parse log files. These log files have lines separated by new line. I was looked at GroupLogFile.scala ...

Harit Himanshu
Oct 6, 2015 at 7:28 pm
Nov 5, 2015 at 3:21 pm

6	[akka-user] Akka and Fibers: Any Plans?

Hello, I find the idea of fibers in Quasar quite compelling, see this blog <http://blog.paralleluniverse.co/2014/02/06/fibers-threads-strands/ . With the use of fibers threads are prevented from ...

Haddock
Oct 26, 2015 at 10:39 am
Oct 28, 2015 at 5:12 pm

6	[akka-user] Akka Persistence: Picking a storage backend

Based on your production experience, what storage backends have worked well for akka-persistence? We are considering postgres because we already use it heavily. Does anyone have experience with this? ...

Vikas
Oct 26, 2015 at 4:49 pm
Oct 27, 2015 at 12:56 am

6	[akka-user] Event-sourcing with aka-persistence

Hello, I am new in Akka and I am trying to develop some mini project to test some things (akka, rx, cqrs, es etc..) I think I understand the concept of cqrs/es and how it fit to akka. My problem is ...

Adam Dohnal
Oct 12, 2015 at 2:08 pm
Oct 25, 2015 at 6:10 pm

6	[akka-user] Persistence of dynamic hierarchy of actors with short/medium length of life

Hi! I've recently encountered puzzling challenge of serializing dynamic hierarchy of actors. In this class of use case actors usually do live very short (seconds) or eventually medium lives (minutes) ...

Robert Budźko
Oct 3, 2015 at 7:44 pm
Oct 22, 2015 at 11:12 am

5	[akka-user] address is now gated for [5000] ms

Hi, I am occasionally getting this when running tests. The test resumes, but I wait for 5 secs. Is there a config property to set it to 500ms? (googling didn't reveal any relevant info) Thanks -- --- ...

Kostas kougios
Oct 7, 2015 at 4:25 pm
Nov 5, 2015 at 2:08 pm

5	[akka-user] Flatten and grouping streams yields 'exceeding it's subscription-timeout'

Hi, My usecase: I get a List of elements that contain ids to download stuff. I want to download everything and afterwards group it together to the corresponding elements. So I tried doing this with a ...

Muki
Oct 4, 2015 at 1:52 pm
Oct 5, 2015 at 9:51 am

4	[akka-user] Akka config to include "common.conf" programmatically

Hi, I have the following configuration which works fine but because we are externalizing so that IT admins have full control of it, we need to be able to mimic the *include "common"* section ...

Guido Medina
Oct 29, 2015 at 2:32 pm
Nov 10, 2015 at 1:53 pm

4	[akka-user] Is Akka Streams using Akka 2.4.0 or an earlier version?

I'm getting some "ambiguous reference" errors in my code relative to two calling signatures for akka.pattern.ask. My project imports Akka 2.4.0 only. Upon research Akka 2.3.x uses one of the ...

Tigerfoot
Oct 23, 2015 at 11:42 pm
Oct 24, 2015 at 3:48 pm

4	[akka-user] Spray 1.3.3 and Aka 2.4

Is this possible? I've learned that migration from Spray to Akka HTTP is not always trivial, and that the performance is not yet there, but would like to benefit from the other goodies in 2.4 ...

Richard Rodseth
Oct 21, 2015 at 9:19 pm
Oct 22, 2015 at 10:42 pm

4	[akka-user] How to scale up or out persistent actor for better throughput

Hi, Is it possible to use persistent actor with router such as to scale out. If you have elasticity with persistent actor you have a problem with your event sourcing. Hence i wonder how to scale up ...

Maatary Okouya
Oct 21, 2015 at 9:29 pm
Oct 22, 2015 at 12:06 am

4	[akka-user] AllocationStrategy rebalance() is stopping actors outside resharding list

Hi. We're using Akka 2.3.13 (Java Interface). We have our own AllocationStrategy implementation and the idea is move several shards from one node to other. We have a 2 nodes in the cluster and 1000 ...

Eduardo Fernandes
Oct 19, 2015 at 11:03 am
Oct 21, 2015 at 12:32 pm

4	[akka-user] Dynamic dependency Injection in AKKA

I'd like to know if there is some pattern to handle dynamic dependency injection. This concern the situation where we have supervision hierarchy. Let say I have a service Z that depend on a service c ...

Maatary Okouya
Oct 16, 2015 at 10:05 am
Oct 19, 2015 at 1:13 pm

4	[akka-user] How many actors can be launched in an ActorSystem ?

Hi, Can anyone specify how many actors can be launched in an ActorSystem if we have close to 10g jvm memory? Thanks, Pradeep -- --- You received this message because you are subscribed to the Google ...

Pradeep Chanumolu
Oct 14, 2015 at 12:02 am
Oct 14, 2015 at 10:18 pm

4	[akka-user] DistributedPubSub, SendToAll (path...) is not sending msg

Path is : akka://testSystem/user/databaseServer/index:int-string There are 2 actors with that path on 2 ActorSystems. ActorSystem = testSystem. None is receiving the msg What can be wrong? -- --- You ...

Kostas kougios
Oct 1, 2015 at 3:00 pm
Oct 5, 2015 at 1:42 pm

4	[akka-user] Circuit breaker reset based upon number of failures within a time window.

Hello All I am evaluating Akka to use in our enterprise application. One of the feature which we are looking for is to find out if we can allow circuit breaker to remain closed when the number of ...

Sandeep Khurana
Oct 1, 2015 at 9:35 am
Oct 5, 2015 at 6:19 am

3	[akka-user] [Akka Cluster 2.4] Rebalancing and Remember entities

Hi guys, I was playing around with Akka Cluster trying to make work a Cluster with two nodes using Cassandra for persistence. This is a demo project I created to reproduce the case ...

Gabriel Volpe
Oct 28, 2015 at 3:07 pm
Oct 30, 2015 at 3:54 pm

3	[akka-user] Integration tests with Stubbed Cassandra

Dear group I am trying to implement some integration tests of my system using Stubbed Cassandra (to test what happens when requests time out etc). The problem is that Akka Persistence makes a lot of ...

Anders Båtstrand
Oct 20, 2015 at 1:01 pm
Oct 22, 2015 at 3:31 pm

3	[akka-user] Changing protocol's case classes

Let's say I have an API gateway that talks to database micro services which have version 0. And in version 0, the query takes a case class with 3 parameters like so: case class Query(param1: String, ...

Lap Ming Lee
Oct 21, 2015 at 11:34 am
Oct 22, 2015 at 6:32 am

3	[akka-user] Strategies to Track if a Message Has been Submitted?

Greetings, I have a situation where I have periodic tasks that will take several minutes. The manager will submit thousands of requests to a particular actor router. When the requests are received, ...

Kraythe
Oct 20, 2015 at 7:07 am
Oct 20, 2015 at 9:06 am

3	[akka-user] [akka-stream] How to get materialization result in partial flow

Hey hAkkers! I need your advise in akka streams materialization question. I have custom protocol source `MySource` of type`Source[String, ActorRef]` which accepts messages to control protocol via ...

Alexey Romanchuk
Oct 16, 2015 at 5:48 am
Oct 19, 2015 at 7:48 am

3	[akka-user] No Tests to run for MultiJvm

Hello everyone, I started learning akka-cluster today and was trying to write the multi-ivm test. I followed all through the document ...

Harit Himanshu
Oct 18, 2015 at 5:16 am
Oct 19, 2015 at 4:47 am

3	[akka-user] Memory model, messages and remoting

Hallo everyone, first thanks for the great framework. I have a question about the akka memory model and remoting. If I have two hosts (A,B) and have the Actors A1,B1,B2, would the SAME message send ...

Olf sync
Oct 16, 2015 at 8:49 am
Oct 18, 2015 at 8:42 pm

3	[akka-user] Dead Letters using Remoting in Cluster

TL;DR: Following TypeSafe activator Distributed worker code, messages from Master/Leader based on actor ref or actor path go to dead letters on target system 1. Worker sends RegisterWorker(id) to ...

Sfosborn
Oct 1, 2015 at 4:33 pm
Oct 14, 2015 at 1:00 am

3	[akka-user] "Returning" a value from an ActorPublisher?

Hi, I am implementing an ActorPublisher that reads records from a database. When the stream is completed I would like to extract some value from the actor (for example the maximum of some field of ...

Jan Algermissen
Oct 10, 2015 at 9:08 pm
Oct 12, 2015 at 9:53 pm

3	[akka-user] [akka-persistence] Hihgest sequence number and deleteMessages in third-party journal.

Hello, Is it true that third-party journal implementation should keep the highest sequence number for persistenceId even if deleteMessages caused complete journal cleanup ? This is how LevelDB ...

Evgeny Shepelyuk
Oct 10, 2015 at 9:46 am
Oct 12, 2015 at 6:55 pm

3	[akka-user] Size limitation for data upload in akka http

I'm using akka http to implement a REST service and that works fine except for one case. The HTTP message parser has a limit on the message size. This means that I cannot upload "large" data using a ...

Daniel Bauer
Oct 7, 2015 at 7:30 am
Oct 8, 2015 at 12:49 pm

3	[akka-user] Akka streams materialization type

Hi, I've been keeping an eye on the development of akka streams, and I was just taking a second look at it now. There is one thing that I can't seem to get my head around, which is the explicit types ...

Robert Wilton
Oct 6, 2015 at 1:29 pm
Oct 7, 2015 at 2:29 pm

3	[akka-user] A simple Akka JMM question

Hi, please see the code at http://pastebin.com/L0WiXTJU Does Akka garantee that changes to the ArrayList "theList" will always been seen by ExampleActor? <http://pastebin.com/L0WiXTJU Or asked ...

John Vieten
Oct 6, 2015 at 7:46 am
Oct 6, 2015 at 8:36 am

2	[akka-user] SharedLeveldbJournal questions

Hi, Now that Akka 2.4 is released with the new persistence-query APIs, we upgraded Akka in our application. After doing some searching, I couldn't find any persistence-query plugins yet, so in the ...

Tal Pressman
Oct 14, 2015 at 11:06 am
Nov 3, 2015 at 2:33 pm

2	[akka-user] akka-http, websockets, and cluster sharding

I have a web service that up until my addition of server-side web socket support, worked fine. I use akka-http to handle HTTP requests, and a cluster sharding region to route messages (sourced from ...

Eric Swenson
Oct 30, 2015 at 6:57 pm
Nov 1, 2015 at 4:01 pm

2	[akka-user] Akka-Spray application losing messages

Hi, Following is my app.conf. I am losing almost 50% of the messages. Is it because of the ClusterRouterPool ? Running it on 2 node cluster(each is m4.xlarge machine) There are two actors- akka { ...

Arpit Rajpurohit
Oct 28, 2015 at 2:51 pm
Oct 30, 2015 at 3:51 pm

2	[akka-user] Messages being loss on an Akka Cluster

Hello, everyone! I am relatively new to the Akka world, and I am leading a project based on the Akka Cluster toolbox for an undergrad course, that will be presented to professors a few weeks from ...

Guilherme Renna
Oct 15, 2015 at 3:25 pm
Oct 29, 2015 at 1:23 pm

2	[akka-user] How to write Flows which perform chunking and unchunking of large Strings?

I am starting to work with akka-streams and have a problem to solve which seems easy but I'm having trouble with it. I have a Source[String, Unit] and the strings can be quite large. I'd like to ...

Kevin Esler
Oct 27, 2015 at 4:18 pm
Oct 27, 2015 at 6:52 pm

2	[akka-user] testing that a message is not send

I want to test the negative of a use case, when a msg shall not be send. TestKit doesn't seem to have something to say dontExpectAnyMessage. TestProbe has a field of how many msgs are available to ...

Kostas kougios
Oct 27, 2015 at 3:35 pm
Oct 27, 2015 at 3:54 pm

2	[akka-user] is akka.actor.ActorNotFound possible after context.actorOf(...)?

I've been debugging this issue for a couple of days now. I am getting an akka.actor.ActorNotFound after doing actor selection and resolveOne. By now I am pretty confident that the actor is created ...

Kostas kougios
Oct 14, 2015 at 3:50 pm
Oct 22, 2015 at 10:40 pm

group	akka-user @
categories	scala
discussions	104
posts	479
users	117
website	akka.io
irc	#akka

summaries	on	Hotkey: s
users list	on	Hotkey: d
user style	avatars	Hotkey: a

Scala > akka-user > October 2015

Search Discussions

104 discussions - 479 posts

117 users for October 2015

Content

People

Support

Translate