Search Discussions
-
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 -
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 Overview
group | akka-user |
categories | scala |
discussions | 115 |
posts | 483 |
users | 119 |
website | akka.io |
irc | #akka |
119 users for February 2015
Archives
- June 2016 (223)
- May 2016 (492)
- April 2016 (498)
- March 2016 (569)
- February 2016 (644)
- January 2016 (387)
- December 2015 (378)
- November 2015 (474)
- October 2015 (491)
- September 2015 (445)
- August 2015 (581)
- July 2015 (589)
- June 2015 (762)
- May 2015 (682)
- April 2015 (558)
- March 2015 (523)
- February 2015 (484)
- January 2015 (604)
- December 2014 (495)
- November 2014 (548)
- October 2014 (596)
- September 2014 (655)
- August 2014 (816)
- July 2014 (662)
- June 2014 (374)
- May 2014 (546)
- April 2014 (508)
- March 2014 (549)
- February 2014 (534)
- January 2014 (706)
- December 2013 (346)
- November 2013 (539)
- October 2013 (569)
- September 2013 (405)
- August 2013 (612)
- July 2013 (466)
- June 2013 (528)
- May 2013 (449)
- April 2013 (458)
- March 2013 (457)
- February 2013 (451)
- January 2013 (611)
- December 2012 (499)