akka-user@googlegroups.com discussions for February 2015

16	[akka-user] Performance Of Akka IO

hAkkers, One of the reasons I chose to implement my RxMongo <https://github.com/reactific/RxMongo driver on Akka was because of the performance and scalability of spray.io which was transitioned into ...

Reid Spencer
Feb 21, 2015 at 7:17 pm
Feb 24, 2015 at 9:56 pm

15	[akka-user] Confusing problem whilst testing a PushPullStage implementation of a sliding window

I was hoping someone might be able to shed some light on an odd issue I'm observing with Akka streaming (version 1.0-M3). I've defined a PushPullStage implementation of a sliding window (see ...

Carl Pulley
Feb 14, 2015 at 1:38 pm
Feb 23, 2015 at 10:39 am

9	[akka-user] Grokking akka-stream and TcpStream

hAkkers, I've been unable to *grok <http://en.wikipedia.org/wiki/Grok * how to communicate with a TCP socket using akka-stream and StreamTcp extension. At this point, I'm not sure the fault is ...

Reid Spencer
Feb 12, 2015 at 4:56 pm
Feb 13, 2015 at 5:46 pm

8	[akka-user] streams - Source that emits only 1 (or no) element

Hi, I was wondering, is Source[T] an abstraction only useful when you can possibly have more than 1 element? Is Future[T] still the way to represent a source that will emit exactly 1 element or an ...

Giovanni Alberto Caporaletti
Feb 15, 2015 at 4:49 pm
Feb 17, 2015 at 1:28 pm

8	[akka-user] Akka HTTP - how to use the HTTP client to send multiple requests on the same connection

I feel like I'm missing something obvious here, but I can't get this to work. Please could someone tell me why the following test fails? I'm using "akka-stream-and-http-experimental-1.0-M2" import ...

Richard Bradley
Feb 11, 2015 at 3:12 pm
Feb 12, 2015 at 12:57 pm

7	[akka-user] akka-http long-lived connection & backpressure problem

Hi, In one of my projects I'm using akka-http's ability to process many requests in a single, long-lived connection. It works fine at the beginning but after dozen or so requests it simply stops - ...

Łukasz Sowa
Feb 8, 2015 at 12:16 am
Feb 28, 2015 at 10:37 am

7	[akka-user] [Akka-stream] Distributed actor communication via Ask pattern or ActorPublisher/ActorSubscriber

Hi, If ActorX needs to pass a load of data to be processed to a remote ActorY, is this a correct think to do? Imagine the data is rows of huge files that are downloaded on ActorX and to be processed ...

Jakub Liska
Feb 21, 2015 at 1:20 pm
Feb 23, 2015 at 2:03 am

6	[akka-user] Shard coordinator persisting actor addresses containing the node IP

Hi! We recently made a mistake by having two separate clusters use the same journal DB which obviously doesn't work but it lead to some questions about how the cluster sharding works. We detected our ...

Johannes Berg
Feb 25, 2015 at 7:06 am
Mar 5, 2015 at 2:03 pm

6	[akka-user] AtLeastOnceDelivery - mapping my own messageId to deliveryId possible?

According to http://doc.akka.io/docs/akka/snapshot/scala/persistence.html#Relationship_between_deliver_and_confirmDelivery : "A function can be created to map your own messageId to deliveryId, which ...

Paweł Kaczor
Feb 4, 2015 at 9:32 am
Feb 22, 2015 at 3:58 pm

5	[akka-user] ClusterSharding and node address/port

Hi, I was experimenting with the ClusterSharding system (the one in master with rememberEntries true) and persistence in a simplistic test that those the following: 1) Start a ClusterSharding region ...

Brice Figureau
Feb 27, 2015 at 3:16 pm
Mar 4, 2015 at 3:30 pm

5	[akka-user] FuncIterable & IterableSource is calling next concurrently

Hey, I'd need to do something like : val iterable = list.toStream.map( non-thread-safe-operation ) val source = Source(iterable) // Source(() = iterable.iterator) source.map (...) but the problem is ...

Jakub Liska
Feb 18, 2015 at 1:35 pm
Feb 21, 2015 at 12:28 pm

5	[akka-user] akka-streams - How to define a Source from an arbitrary event stream?

I struggle in nicely defining a Source that gets its elements from an arbitrary event stream. At the moment my code looks like this: def watchKey[A : Reads](key: SettingKey[A])(implicit ctx ...

Simon Schäfer
Feb 19, 2015 at 10:42 pm
Feb 21, 2015 at 11:39 am

5	[akka-user] Actor Threading spec

I heard somewhere that by default an Actor system, meaning its ExecutorService/Dispatcher was creating a pool of Non-Deamon thread to run Actor. If it is indeed really the case, and that would ...

Maatary Okouya
Feb 12, 2015 at 8:06 pm
Feb 13, 2015 at 11:43 am

5	[akka-user] Future and Thread.

Hi, by default, on which kind of Thread is a future executed ? Example: when i run the following program object ThreadAPP extends App { import scala.concurrent.ExecutionContext.Implicits.global val ...

Maatary Okouya
Feb 12, 2015 at 8:32 pm
Feb 13, 2015 at 11:35 am

5	[akka-user] How to execute the defer-callback before processing the next command?

Dear users I find the semantics of "defer" confusing. I thought defer was the same as persist, except the given message was not persisted. Now today, when a bug got me to read the doc again, it ...

Anders Båtstrand
Feb 4, 2015 at 1:23 pm
Feb 9, 2015 at 2:04 pm

5	[akka-user] Does akka support fiber/coroutine? (do not modify source code)

Hello, Does akka support fiber/coroutine? I found that all akka's dispatchers rely on JVM threads now. Is there any way to config dispatchers which could run actor on fiber/coroutine? (do not modify ...

Chansey97
Feb 6, 2015 at 6:57 pm
Feb 6, 2015 at 7:28 pm

5	[akka-user] new project - akka streams/http - is using the current spray release with akka streams and migrating later too painful?

Hi, I need to start a new project in a couple of months (and hopefully have a first working prototype in 2-3 months more). I am a rxscala/java user, and am following the reactive streams/akka streams ...

Giovanni Alberto Caporaletti
Feb 2, 2015 at 11:53 pm
Feb 6, 2015 at 5:40 pm

5	[akka-user] akka 2.4.0 release date?

this is now past due: https://github.com/akka/akka/milestones/2.4.0 can someone in the "know" please update us on the akka 2.4.0 release date? -- --- You received this message because you are ...

Andrei Pozolotin
Feb 4, 2015 at 8:27 pm
Feb 5, 2015 at 4:39 pm

4	[akka-user] Stop TestActorRefs that fail?

Hi, I am testing an Actor and mocking out one of its dependencies. When the test fails, e.g. an unexpected call to the mock (which causes an exception) the Actor is restarted and all I end up with is ...

Sam Halliday
Feb 26, 2015 at 4:24 pm
Mar 2, 2015 at 2:00 pm

4	[akka-user] akka-persistance - nested persist

Hi, I'm in a situation where it would be lovely to be able to do a "nested persist", i.e.: persist(SomeEvent)(handle) ... def handle = { case SomeEvent = changeState() ...

Manuel Bernhardt
Feb 20, 2015 at 1:50 pm
Mar 2, 2015 at 8:07 am

4	[akka-user] [akka-http] Routing dsl and streams integration

Hello! As I understand from docs akka-http seamless integrates with akka-stream by passing flow to handleWith method. Also we have well known routing dsl from spray with all these nested directives ...

Alexey Romanchuk
Feb 10, 2015 at 3:21 am
Feb 27, 2015 at 4:09 pm

4	[akka-user] Best way to write unit tests on an Akka actor

I am a relative newbie to testing Akka actors. What I am trying to accomplish is: How do I unit test the following Actor whose description I have laid out below: *Description:* I am trying to test an ...

Marco Polo
Feb 6, 2015 at 3:33 pm
Feb 22, 2015 at 12:23 pm

4	[akka-user] ANNOUNCE: Akka Streams & HTTP 1.0-M3

Dear hakkers, it has been over a month, so we figured that another milestone of our Streams & HTTP projects is in order. The Christmas break was a bit longer on the HTTP side (i.e. not so many ...

Roland Kuhn
Feb 6, 2015 at 2:56 pm
Feb 17, 2015 at 11:50 am

4	[akka-user] Aboud Actor using Future

Hi ALL, I found this in the akka documentation 1. import akka.dispatch.*; 2. import scala.concurrent.ExecutionContext; 3. import scala.concurrent.Future; 4. import scala.concurrent.Await; 5. import ...

Krishna Kadam
Feb 11, 2015 at 7:51 am
Feb 12, 2015 at 12:59 pm

4	[akka-user] ActorRefProvider.actorSelection cannot find a PromiseActorRef

Hi all, I got a path of a PromiseActorRef and try to send a message to this path. It seems the message will not be received by the PromiseActorRef. class SimpleActor extends Actor { override def ...

IL
Feb 7, 2015 at 7:49 pm
Feb 8, 2015 at 9:15 am

3	[akka-user] Dead letter JournalProtocol#WriteMessageSuccessful

Dear users Sometimes I find dead letter JournalProtocol#WriteMessageSuccessful in my logs, after I have stopped my actor. As I understand it, stop involves a message send, so all write operations ...

Anders Båtstrand
Feb 27, 2015 at 12:26 pm
Mar 4, 2015 at 5:46 pm

3	[akka-user] ANNOUNCE: Akka Streams & HTTP 1.0 MILESTONE 4

Dear hakkers, we are pleased to announce the availability of the fourth milestone of Akka Streams & HTTP. The biggest directly visible feature of this release is a completely new and fluent Java DSL ...

Roland Kuhn
Feb 27, 2015 at 4:08 pm
Feb 28, 2015 at 12:47 pm

3	[akka-user] [Akka Http 1.0-M4] startHandlingWith / starting server with routes

Hello, I have been playing around with Akka Http the last few days, starting with the excellent Typesafe Activator akka-http-microservice <https://github.com/theiterators/akka-http-microservice ...

Peter Neyens
Feb 27, 2015 at 7:14 pm
Feb 28, 2015 at 6:31 am

3	[akka-user] akka system shutdown in sub actor

Hi all, I have some program like this, a master actor, several worker actor, a listener actor. Besides that, I have a driver class to create Akka system and send start message to master. Master ...

George Lu
Feb 26, 2015 at 9:28 am
Feb 27, 2015 at 4:21 pm

3	[akka-user] akka-http custom directives

Hi - is there any documentation (even in draft form) about custom directives for akka-http? Or has anyone any code examples? Thanks Tim -- --- You received this message because you are subscribed to ...

Tim Pigden
Feb 27, 2015 at 9:56 am
Feb 27, 2015 at 3:18 pm

3	[akka-user] Many concurrent network connections

Hello, I have a questions concerning holding many network connections and whether Akka can handle this. Let's say a system needs to be able to hold 50.000 network connections at the same time. So ...

Haddock
Feb 25, 2015 at 1:35 pm
Feb 27, 2015 at 7:26 am

3	[akka-user] how do I configure a different dispatcher for an ActorProducer?

Hi again, I have another question. Let's say that I write a blocking ActorProducer (could be anything, external service, database, whatever), and I want it to use a specific dispatcher explicitly ...

Giovanni Alberto Caporaletti
Feb 18, 2015 at 11:54 pm
Feb 26, 2015 at 9:16 pm

3	[akka-user] Performance issue with akka-remoting

Hi All, I have a system where an actor sends a message to a remote actor and waits for that actor to respond. Some times these messages can be really large (several MiB). The round trip is taking in ...

Moiz Raja
Feb 17, 2015 at 3:09 am
Feb 24, 2015 at 5:42 pm

3	[akka-user] Reasons why Logback is recommended for Akka logging

Hi, In the Akka documentation <http://doc.akka.io/docs/akka/current/java/logging.html#logging-java Typesafe recommend using Logback as the runtime SLF4J backend logger. I'm just wondering what the ...

Martin Ford
Feb 23, 2015 at 12:43 pm
Feb 24, 2015 at 2:25 am

3	[akka-user] akka-http outgoing connection recovery

Hi, In my application I have a quite complex flow built on top of long-lived http connection (via `Http().outgoingConnection`). If the other end (server) of this connection goes down (connection is ...

Łukasz Sowa
Feb 15, 2015 at 2:52 am
Feb 22, 2015 at 8:19 pm

3	[akka-user] Response reason phrase exceeds the configured limit of 64 characters

Hi - I get the following. Not sure how to find out what the response was or how to change the configuration. Any help much appreciated as I'm now stuck. akka.http.model.IllegalResponseException ...

Tim Pigden
Feb 21, 2015 at 3:09 pm
Feb 21, 2015 at 11:44 pm

3	[akka-user] Error details for Tcp.Bind

Hello, I've been wondering whether it's possible to get underlying exception in Tcp.CommandFailed on Bind? Looking at ...

Yuri Ushakov
Feb 17, 2015 at 7:50 am
Feb 19, 2015 at 11:45 am

3	[akka-user] Quarantined nodes due to temporary network partition

Hi! I've had some problems handling temporary network partitions/communication problems which causes nodes to get quarantined. Earlier I've found out that I can hit the system message buffer size ...

Johannes Berg
Feb 11, 2015 at 12:43 pm
Feb 13, 2015 at 10:39 am

3	[akka-user] Handling of Fatal errors

Hello, I have Akka configured not to exit JVM on fatal errors by setting the "akka.jvm-exit-on-fatal-error" property to "off". In such case, it's expected to shutdown the actor system. (As a side ...

Andrey
Feb 10, 2015 at 4:23 pm
Feb 11, 2015 at 4:03 pm

3	[akka-user] Multiple sharded actors for the same entry

Hi, I have a problem where multiple actors for the same entry id are running in the cluster. We have two nodes that are both running a ShardRegion and the sharded actors. By analyzing logs I've ...

Magnus H
Feb 5, 2015 at 4:13 pm
Feb 9, 2015 at 7:39 pm

3	[akka-user] akka.io downloads - no java?

I feel pretty stupid for asking this, but if I wanted to experiment with Akka for Java, where would I find it? For all the Java/Scala parallel documentation, the downloads section of the site only ...

Jeffrey Kelly
Feb 8, 2015 at 9:50 pm
Feb 9, 2015 at 8:21 am

3	[akka-user] Is there any way to change actor's hierarchy (eg: orphan actor)

Hello, I am creating a rendering system in my game engine. I found that Akka is a good solution for this. My quesion is: Is there any way to change actor's hierarchy (eg: orphan actor) For instance, ...

Chansey97
Feb 3, 2015 at 3:37 pm
Feb 6, 2015 at 6:59 pm

3	[akka-user] Akka stream and akka cluster

Hey hakkers! Do you have any plans to implement clustered stream materializer to distribute stream parts in cluster? If yes do you have any estimations or ETA? Right now it is possible to manually ...

Alexey Romanchuk
Feb 4, 2015 at 6:10 am
Feb 6, 2015 at 4:53 pm

3	[akka-user] Make unstash() public

Hi, does anything speak against making unstash() <https://github.com/akka/akka/blob/v2.3.9/akka-actor/src/main/scala/akka/actor/Stash.scala#L186 public (currently private[akka])? In my use case, it ...

Martin Krasser
Feb 5, 2015 at 3:30 pm
Feb 5, 2015 at 4:26 pm

3	[akka-user] Https support for akka-http

Hi all, any estimate on when we can expect https support for akka-http? Will it be part of 1.0, or will we have to wait longer? I don't need anything fancy. Just the ability to connect to a REST api ...

Rklaehn
Feb 3, 2015 at 8:41 am
Feb 3, 2015 at 11:59 pm

3	[akka-user] [akka-http 1.0-M2] Trying to add backpressure

Dear hakkers, I have been trying to add back pressure to an akka-http application using a transformation Stage and I have found something... unexpected. I have created a SafetyStage that buffers up ...

Luis Ángel Vicente Sánchez
Feb 3, 2015 at 7:57 pm
Feb 3, 2015 at 8:16 pm

3	[akka-user] Akka Stream: How to dynamically group elements?

I am looking to batch elements in a flow in a non-standard way and sending them off. A typical flow for this based on a static count would look like this: Source[Element] .grouped(batchSize) ...

Elmar Weber
Feb 2, 2015 at 5:45 pm
Feb 2, 2015 at 11:53 pm

2	[akka-user] Problem with supervision strategy & akka-stream 1.0-M4

Hello! I'm very inspired of Reactive streams idea and akka implementation. But i found some discourage fact in 1.0-M4: Why is the stream supervisor works only for one exception and other exceptions ...

Igor Perevozchikov
Feb 28, 2015 at 11:28 am
Mar 3, 2015 at 10:54 am

2	[akka-user] akka-http client broken by M4, any suggestions what to do to fix?

Hi, Can anyone help fix this M3 sample? My code for M3 which I think I scrounged from some code fragment out there on the web looks like this: def response(req: HttpRequest): Future[HttpResponse] = { ...

Tim Pigden
Feb 27, 2015 at 6:05 pm
Feb 28, 2015 at 8:24 am

2	[akka-user] The mapAsync and the mapAsyncUnordered an unexpected behavior

I have a simple actor publisher: class TestActor extends ActorPublisher[Int] { println("RUN") def receive = { case Request(elements) = while (totalDemand 0 && isActive) { onNext(1) } case Cancel = ...

Boris Lopukhov
Feb 27, 2015 at 9:42 am
Feb 27, 2015 at 12:43 pm

group	akka-user @
categories	scala
discussions	115
posts	483
users	119
website	akka.io
irc	#akka

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

Scala > akka-user > February 2015

Search Discussions

115 discussions - 483 posts

119 users for February 2015

Content

People

Support

Translate