akka-user@googlegroups.com discussions for March 2015

18	[akka-user] Akka Stream 1.0M5 : buffersize = 0

Actually ActorFlowMaterializerSettings is complaining about initialInputBufferSize = 0. What are the reasons you can't disable buffering elements by setting initialInputBufferSize and ...

Peter Schmitz
Mar 30, 2015 at 7:22 am
Apr 16, 2015 at 12:20 pm

11	[akka-user] Cluster Metrics CPU/load reporting very inaccurate

Hi! I've been working with some monitoring of the cluster through the ClusterMetrics provided in Akka 2.3.9 using hyperic-sigar-1.6.4. I've been comparing what is displayed in top and what I get by ...

Johannes Berg
Mar 20, 2015 at 3:03 pm
Mar 30, 2015 at 10:24 am

11	[akka-user] Cluster: Multiple leaders / ReachableMember not propagated / ...?

Hello. We did tests with akka cluster and Unreachable / Reachable state and discovered the following reproducible behaviour, which might be a problem - but still unsure :-) ====== Environment: ====== ...

Michaels
Mar 10, 2015 at 12:15 pm
Mar 16, 2015 at 2:25 pm

10	[akka-user] Implicit value issue for FromRequestUnmarshaller in akka-http with spray-json

Hi. I was faced with a typical error with spray-json and akka-http that easy to find in Google, but none of solutions helps me. Scala fail compiling in place where I parsing request body with ...

Arthur Kushka
Mar 15, 2015 at 11:16 pm
Jul 29, 2015 at 4:45 am

10	[akka-user] Access to current message in actor

Hi there - Somewhat regularly I have a need to access the current message in an actor method outside of the receive. It's usually some case where I want to do something generic with it, like ...

Eric Pederson
Mar 17, 2015 at 7:53 pm
Mar 26, 2015 at 3:18 pm

9	[akka-user] Memory leak somehow related to ask pattern

Hi guys, I have a very strange problem, it was originally spotted by @gfduszynski https://github.com/EventStore/EventStore.Akka.Persistence/issues/11 Here is a problematic line of code ...

Yaroslav Klymko
Mar 28, 2015 at 7:33 pm
Mar 31, 2015 at 8:47 am

8	[akka-user] Akka Streams 1.0 release date?

Dear All, Is there any projected timeframe for releasing version 1.0? After the release of 1.0-M4, I wasn't sure how close Akka was to the official 1.0 release of streams. Thank you, Ali Beyad -- --- ...

Ali Beyad
Mar 9, 2015 at 6:24 pm
Mar 26, 2015 at 1:07 pm

8	[akka-user] Re: Problems using a Remote Actor

Hi, sorry but even after some small changes I'm still stuck with the problem, tried with Akka-2.2.4, 2.2.5, 2.3.9 . From local actor system all works good. I don't really understand the error when ...

Sandro Martini
Mar 10, 2015 at 9:32 am
Mar 23, 2015 at 4:30 pm

8	[akka-user] maximum value for "nr-of-instances" for remotely deployed routees

Is there a maximum value set for "nr-of-instances"? When I set it to 300, it works fine. When I set it to 400, I see "[WARN] [xxx-akka.remote.default-remote-dispatcher-5] [Remoting] Association to ...

Kyunam Kim
Mar 5, 2015 at 6:24 am
Mar 6, 2015 at 5:03 pm

7	[akka-user] Cutsom Flow(Processor) actor

Hi! I would like to use custom actor which implements ActorPublisher and ActorSubscriber as a stage in Flow and pass it to HTTP connection.handleWith. However I can't find any references how to ...

Zeronineseven
Mar 23, 2015 at 7:31 pm
Mar 31, 2015 at 1:31 pm

7	[akka-user] Shutting down an akka stream

Suppose you have a akka stream backed by an ActorPublisher that listens to a continuous stream of data from a messaging system Then how do you cancel this stream ? When you create the source you pass ...

Jelmer Kuperus
Mar 1, 2015 at 10:23 pm
Mar 8, 2015 at 1:49 pm

6	[akka-user] Akka Http Gzip Json

I am trying to put together a route that does a decode with Gzip, and then uses an entity(as. With gzip decoding on, my route is not running. If I remove Gzip, then everything works fine. Here is the ...

Paul Cleary
Mar 23, 2015 at 1:26 pm
May 7, 2015 at 3:35 pm

6	[akka-user] Looking for a good Akka spare time learning project

Hello, I would like to develop a little Akka project with Scala in my spare time. I have been exposed to concurrent programming before and therefore think I have a not so bad understanding of acors ...

Haddock
Mar 17, 2015 at 2:25 pm
Mar 19, 2015 at 2:20 pm

6	[akka-user] akka-persistence: persistAsync interaction with snapshots

Hi, Sorry in advance if this has already been answered somewhere, I couldn't find it... I have a PersistentActor, and I use persistAsync to persist its events. Now I want to add snapshots into the ...

Tal Pressman
Mar 3, 2015 at 3:38 pm
Mar 11, 2015 at 8:57 am

6	[akka-user] akka-streams 1.0-m4 load balancer creation stuck

I'm trying to create a generic load balancer and the code looks like this: import akka.stream.scaladsl.{ Merge, Broadcast, FlowGraph } import akka.stream.{ FlowShape, Graph } object Balancer { def ...

Luis Ángel Vicente Sánchez
Mar 3, 2015 at 1:49 pm
Mar 3, 2015 at 2:52 pm

5	[akka-user] Getting started with Akka persistence - unable to replay messages

I am trying to write a very basic app where messages are sent to an actor at a higher rate, messages are being consumer by the actor at a slower rate, and then after some time, killing the app. When ...

Neeraj agarwal
Mar 20, 2015 at 8:58 am
Mar 23, 2015 at 11:03 am

5	[akka-user] akka-streams constructing Source from Iterator

I have been looking at akka-streams 0.7 and there used to be IteratorSource which could be used by passing Iterator. akka-streams 1.0-M4 no longer has IteratorSource but it has a Source object that ...

Apiwoni
Mar 19, 2015 at 4:32 pm
Mar 23, 2015 at 10:41 am

5	[akka-user] Problem with akka tcp streams

Hi! I want to stream file lines through tcp to server. Here is the code: class StreamingTcpActor(remoteAddress:InetSocketAddress, system: ActorSystem){ implicit val actorSystem = system implicit val ...

Zergood
Mar 19, 2015 at 12:54 pm
Mar 23, 2015 at 9:43 am

5	[akka-user] How to use Cluster Sharding, Please do reply it's very urgent

Hi all, I am a student and trying to use akka to design *scalable distributed real time aggregation system.* I have a scenario in which I parse keys from a message and also creates jobs identified by ...

Krishna Kadam
Mar 16, 2015 at 1:45 pm
Mar 17, 2015 at 6:49 pm

5	[akka-user] Akka streaming 1.0-M4

I'm updating from com.typesafe.akka:akka-stream-experimental_2.10:1.0-M4 to com.typesafe.akka:akka-stream-experimental_2.10:1.0-M4 but there are no classes like UndefinedSource, UndefinedSink, ...

Bogdan Nechyporenko
Mar 6, 2015 at 10:08 am
Mar 6, 2015 at 7:43 pm

4	[akka-user] Context of event stream elements

I'm a newbie with Akka Streams so please excuse me if the question seems stupid. I have the need to pass some context info along with the events in a stream. For example, I have something like the ...

Matthew
Mar 11, 2015 at 8:29 pm
Jul 21, 2015 at 11:48 pm

4	[akka-user] CORS Support Akka-http

Hello, I am currently experimenting with Akka-http on one of our modules. *Below (or attached) is my current CORS file for spray*. I am struggling with conversion, for e.g.: I cant find alternative ...

Ganta Murali Krishna
Mar 10, 2015 at 2:14 pm
Jun 18, 2015 at 4:23 pm

4	[akka-user] BalancingPool - ConfigException$BadPath

Hi, In my code, I am creating a pool in the following standard manner: private lazy val scriptProcessor: ActorRef = context.actorOf(BalancingPool(poolSize).props(ScriptProcessor.props()), ...

Sinel
Mar 11, 2015 at 3:27 pm
May 22, 2015 at 1:03 pm

4	[akka-user] cluster-singleton questions

Hi, A couple of questions regarding the cluster-singleton functionality: - Are there any way of not having all cluster-singleton actors running on the same node ( the leader node of the cluster ) in ...

Olle Martensson
Mar 31, 2015 at 8:43 am
Apr 13, 2015 at 8:08 am

4	[akka-user] ANNOUNCE: Akka Stream & HTTP 1.0 MILESTONE 5

Dear hakkers, it has been four weeks since the last milestone was published, so it is high time for the next one. The user-visible changes we have been doing are getting smaller now, cleaning up a ...

Roland Kuhn
Mar 27, 2015 at 9:05 pm
Mar 31, 2015 at 10:11 am

4	[akka-user] akka streams how to read lines of strings from http body stream

Hi I need to process an endless stream of data from ws response. Writing data to disk first, and then process it would not be a good solution. Could it be done with akka streams, reading the body as ...

Borut
Mar 24, 2015 at 5:00 pm
Mar 27, 2015 at 8:57 pm

4	[akka-user] akka-http: combine path together

Hi, when I combine path together, the resource is never found: path("v2.0" / "tokens") { post { complete("it works") } } path("v2.0") { path("tokens") { post { complete("it does not work") } } } Am I ...

Yann Simon
Mar 10, 2015 at 2:15 pm
Mar 10, 2015 at 8:07 pm

4	[akka-user] (re-)Chunking Source of ByteStrings, filling the gaps

Hi all, Following some helpful advice on this forum, I've been using the Chunker as defined on the Akka Streams cookbook page ...

Dan costelloe
Mar 5, 2015 at 4:15 pm
Mar 6, 2015 at 9:21 am

4	[akka-user] Streams M4: Reasons behind the new MAT type parameter/why does .to default to Keep.left?

I'm trying to better understand the new api. If I got it right, the new type parameter of the various stream components represents the type of what's materialized by that component when the stream is ...

Giovanni Alberto Caporaletti
Mar 2, 2015 at 9:54 pm
Mar 4, 2015 at 9:45 am

4	[akka-user] [Streams 1.0-M4] From Source[Future[T], Unit] to Source[T, Unit]?

Hello, as an input I have Source[PageDetails, Unit] and I also have method which transform PageDetails to Future[CategoryVector] : def categorizePage(page: PageDetails): Future[CategoryVector] By ...

Kermitas
Mar 2, 2015 at 6:03 pm
Mar 3, 2015 at 10:21 am

3	[akka-user] Router Resizing

Hi, I am new to Akka and am exploring router resizing feature of Akka.I have a doubt here that once the router increases the number of routees at a given time , cant it also decrease the number.I ...

Zen
Mar 31, 2015 at 1:41 pm
Apr 10, 2015 at 9:05 am

3	[akka-user] Akka thread pool metrics

Are there some integration points within the Akka framework where it is possible to get information about individual thread pool usage? Regards, Nils-Helge Garli Hegvik -- --- You received this ...

Nilsga
Mar 30, 2015 at 8:57 am
Apr 3, 2015 at 11:24 pm

3	[akka-user] Akka-Http with ActorPublisher source

Hi, I have built a small HTTP EventSource endpoint prototype based on akka-streams-1.0-M3 for a system that I am working on. It turned quite well. I have tried to upgrade it to 1.0-M5 and I can't ...

Любен Каравелов
Mar 30, 2015 at 11:20 pm
Apr 3, 2015 at 2:00 pm

3	[akka-user] Testing FSM with failing Future

Hello - I have an FSM that spawns a future on one of its transitions. I pipe the result of the future to the FSM. The future can fail and I'd like to stop the FSM and report the error. class ...

Anton Khodakivskiy
Mar 27, 2015 at 6:00 am
Mar 30, 2015 at 7:46 am

3	[akka-user] Make Akka Stream Source() work with Either value

Hi, I'm trying to use Akka Stream to parallelize a sequence of operations..and I have those types: type OrdinalRow = Vector[String] type NamedRow = Map[String, String] type NormalRow= ...

Allen Nie
Mar 29, 2015 at 10:15 pm
Mar 29, 2015 at 11:36 pm

3	[akka-user] Get Aggregated Result from Multiple Actors

Example Scenario: 1. Client will create a command *MakePayment*(clientId: Int, amount: Int) 2. There are two actors: *ClientActor* and *FinanceActor* 3. First verify if clientId is correct from ...

ROSHAN SHARMA
Mar 25, 2015 at 10:36 am
Mar 27, 2015 at 4:34 pm

3	[akka-user] Actor Vs Future performance

Hi, I am trying to figure out the difference in performance when it comes to using actors and futures. Either I use one actor per request or Make it async using a Future block. Only form performance ...

Akhil
Mar 26, 2015 at 4:57 pm
Mar 27, 2015 at 11:23 am

3	[akka-user] No in-memory snapshot store?

Dear group Is there no in-memory snapshot store, as there is an in-memory journal? Is there a reason for this? I find that very useful for testing, and wonder if I should file a feature-request for ...

Anders Båtstrand
Mar 26, 2015 at 1:03 pm
Mar 26, 2015 at 2:09 pm

3	[akka-user] kernel parameters needed to use Akka IO

Hi all, We are using Spray IO (with the wandoulabs WebSockets layer) on really old RHEL5 boxes in our QA environments. Bizarrely, our server beta release was working fine on one box, but failing to ...

Sam Halliday
Mar 19, 2015 at 11:42 am
Mar 25, 2015 at 1:20 pm

3	[akka-user] activator-akka-distributed-workers

Hi - I have a question on the akka-distributed-workers example on activator. Is someone able to explain how multiple masters in the cluster are prevented from submitting different work items to the ...

Ben Wimpory
Mar 20, 2015 at 8:58 am
Mar 24, 2015 at 10:11 am

3	[akka-user] Can Cluster Sharding work across applications?

I have two halves of an application, a front-end that is busy with ingesting data, and a backend for processing the data. Is it possible to have the front-end "forward" messages to the back-end using ...

Paul Cleary
Mar 20, 2015 at 7:54 pm
Mar 21, 2015 at 9:58 am

3	[akka-user] Transferring data in between cluster nodes

Hi, What would be the best practice to transfer data (an immutable Map which could be of size from 1MB to 100 MB) in between two nodes in a an Akka Cluster? I initially thought of dividing the map ...

Ömer Faruk Gül
Mar 19, 2015 at 3:41 pm
Mar 19, 2015 at 6:58 pm

3	[akka-user] Help with design of Akka cluster and remote workers

Hey guys, We're currently using RxJava, and we would like to attempt to integrate Akka as a our distributed work system in the Usergrid project. http://usergrid.incubator.apache.org/ I've gone ...

Todd Nine
Mar 15, 2015 at 6:39 pm
Mar 19, 2015 at 6:52 pm

3	[akka-user] Stream Materialization, a larger discussion.

I've been following Akka Streams for bit. I've noticed the changes in M4 and of course read the materialization sections of ...

Jim Hazen
Mar 5, 2015 at 8:30 pm
Mar 18, 2015 at 6:23 am

3	[akka-user] Stop shard region gracefully

Hello, how is it possible to stop a shard region and all the shards located on the same node gracefully? Thanks a lot Hannes -- --- You received this message because you are subscribed to the Google ...

Hannes Stockner
Mar 12, 2015 at 4:24 pm
Mar 12, 2015 at 9:44 pm

3	[akka-user] Akka http - complete with headers

Hi, Completing a route with a Tuple3[StatusCode, Seq[HttpHeader], T] doesn't seem to work for me. My json4s marshaller serializes the whole tuple as an object. Tuple2[StatusCode, T] works instead ...

Giovanni Alberto Caporaletti
Mar 12, 2015 at 12:10 am
Mar 12, 2015 at 10:27 am

3	[akka-user] akka-http: Completing RequestContext with a Future ?

Hello, I’m struggling to understand how I can complete an akka-http RequestContext asynchronously, using a future. Synchronously completion is straightforward, e.g…... val bundleRoutes = { ...

James Mulcahy
Mar 11, 2015 at 10:29 pm
Mar 12, 2015 at 12:07 am

3	[akka-user] system.actorSelection not working when untrusted mode is turned on

Hi! I am using akka 2.3.7. I want to protect my remote actors against PoisonPills from outside. Therefore I set the property akka.remote.untrusted-mode = on (as suggested in ...

James Brems
Mar 6, 2015 at 12:49 pm
Mar 9, 2015 at 12:06 pm

3	[akka-user] BalancingPool work donation logic for dynamic and mixed pool of actors

Hi, I have downloaded and observed the code of the BalancingPool class from the Akka trunc on github (git@github.com:akka/akka.git). Of course, although often described as "work stealing", the code ...

Matan Safriel
Mar 7, 2015 at 4:14 pm
Mar 9, 2015 at 9:13 am

3	[akka-user] [Streams] Is supervision strategy supposed to work with ActorPublishers?

Hey, when ActorPublisher does : "onError(exceptionRegisteredInSupervisionDecider)" then the stream just fails with that exception. Supervision strategy doesn't work here. Is it supposed to or it ...

Jakub Liska
Mar 3, 2015 at 10:22 pm
Mar 6, 2015 at 11:30 am

group	akka-user @
categories	scala
discussions	131
posts	522
users	136
website	akka.io
irc	#akka

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

Scala > akka-user > March 2015

Search Discussions

131 discussions - 522 posts

136 users for March 2015

Content

People

Support

Translate