Search Discussions
-
Hello I am trying to implement a lower level TCP server using Akka. What I mean is when the server receives bytes it should be able to make decisions on the number of bytes received or the byte ...
Vinay Gajjala
Jun 17, 2016 at 9:20 pm
Jun 17, 2016 at 9:20 pm -
Hi all, I'm trying to create a scenario where I have two sets of workers (behind a Router) where the first set of workers is responsible for sending an HTTP request (using Akka HTTP Client) and the ...
Luciano Molinari
Jun 17, 2016 at 9:20 pm
Jun 17, 2016 at 9:20 pm -
Hi I am trying to write actors to encapsulate the cache access by the code. In one of the use case I need to make a decision based on the value in the cache. I am trying not to use the ask() instead ...
Vinay Gajjala
Jun 17, 2016 at 9:20 pm
Jun 18, 2016 at 8:37 am -
Hi All- I'm prototyping a system that will use cluster sharding at a shop where Operations generally does rolling deployments-so it deploys an application one host(of a cluster) at a time. Is there ...
Michael Kohout
Jun 17, 2016 at 7:21 pm
Jun 17, 2016 at 7:21 pm -
I am quite new to akka-http and especially to websockets. I have a service which runs on `localhost:8080` and has a path `/greeter`. When a request comes on this path then it forwards the request to ...
Sonu Mehrotra
Jun 17, 2016 at 12:58 pm
Jun 17, 2016 at 12:58 pm -
Hi all: I' m using akka-http, there is a service provide the "query" method I have to use. How to extends HTTP methods in akka-http? Thanks and regards, wuzhonglin -- --- You received this message ...
Zhonglin wu
Jun 17, 2016 at 7:38 am
Jun 17, 2016 at 8:22 am -
How does the abstract persistent actor recover messages? Does it recover all messages or only that were not delivered? Since we dont have confirm messages how will it work? We tried using AtleastOnce ...
Amruta
Jun 16, 2016 at 5:17 pm
Jun 16, 2016 at 5:17 pm -
i am using akk-http and i using it first time basically i am getting confuse in routes, i want to maintain routes in different classes . is akka support that ? -- --- You received this message ...
hamza Sharif
Jun 16, 2016 at 9:21 am
Jun 16, 2016 at 9:23 am -
Hi all, I'm working with Akka Streams for the first time and I am running into something a bit confusing. I have an ActorPublisher for my source and an ActorSubscriber for my sink. Everything works ...
Devin Carlen
Jun 15, 2016 at 8:03 pm
Jun 15, 2016 at 8:03 pm -
Hello, Have anyone here ever tried using akka-http with the play-ws library? I know that akka-http have a built-in client support ...
Pishen tsai
Jun 15, 2016 at 11:25 am
Jun 16, 2016 at 11:20 am -
Hello All, I've designed the application with AKKA + Spring Framework IOC + Spring Scheduler. Currently I shutdown the AKKA system for each run and recreate it in the next execution when the ...
Yan Pei
Jun 14, 2016 at 4:29 pm
Jun 16, 2016 at 4:46 pm -
Hi all, I have a question about integration akka with spring,how to integration akka with spring? -- --- You received this message because you are subscribed to the Google Groups "Akka User List" ...
朱怀琦
Jun 14, 2016 at 6:06 am
Jun 17, 2016 at 7:24 pm -
Greetings, I have a large map of serialization bindings basically in a big map where type ids are defined that I would like to inject into the config at startup but I have been unable to figure out ...
Kraythe
Jun 13, 2016 at 7:50 am
Jun 13, 2016 at 8:16 am -
Hi all, I have a very small stream that takes data from a GraphStage and pushes it to a file: val (killSwitch, flow) = dataSource .viaMat(KillSwitches.single)(Keep.right) ...
Brian Topping
Jun 12, 2016 at 8:04 am
Jun 12, 2016 at 11:44 pm -
I am trying to achieve two way real time communication between akka-http websocket server and client server code : object EchoService { def route: Route = path("ws-echo") { get { ...
Chandra sekhar kode
Jun 12, 2016 at 5:14 am
Jun 12, 2016 at 5:14 am -
The use case is I have a bunch of entities that are in an RDBMS and they are represented in memory by an actor per entity and those entities are spread across the cluster using ClusterSharding ...
Kraythe
Jun 11, 2016 at 6:14 pm
Jun 12, 2016 at 5:49 pm -
override def preStart = { super.preStart val persistenceIdsSink = Sink.actorRef(self, MyViewActor.Protocol.PersistenceIdsComplete) val source: Source[MyId, NotUsed] = ...
Aditya Prasad
Jun 10, 2016 at 11:15 pm
Jun 10, 2016 at 11:15 pm -
Greetings, I apologize if this has been asked but I am having what I assume is a config problem. When I start a single node I get the following logged errors and my sharded actors don't start. The ...
Kraythe
Jun 10, 2016 at 7:18 pm
Jun 13, 2016 at 7:45 am -
Dear hakkers, We’re excited to announce that we have released the second development milestone of the new Akka Remoting, which has the code named Artery. It’s an early development preview and we ...
Patrik Nordwall
Jun 10, 2016 at 3:46 pm
Jun 14, 2016 at 9:52 am -
The following code example (which you can copy and run) shows a MyParentActor that creates a MyChildActor. The MyChildActor throws an exception for its first message which causes it to be restarted ...
David Joyce
Jun 10, 2016 at 1:17 pm
Jun 10, 2016 at 1:17 pm -
I have Akka application which is essentially traverses a very large tree where each vertex processing is done by an individual actor. Different kinds of vertices are processed by different actors ...
Mark Kaberman
Jun 10, 2016 at 12:55 pm
Jun 14, 2016 at 2:47 pm -
I'm trying to test that I'm loading configurations properly, and just can't seem to create the configuration properly - and getting nowhere in tracking down what I'm doing wrong on my own. Here's a ...
Ian Nowland
Jun 9, 2016 at 5:29 pm
Jun 9, 2016 at 7:05 pm -
http://stackoverflow.com/questions/37727410/how-to-listen-websocket-server-close-events-using-akka-http-websocket-client -- --- You received this message because you are subscribed to the Google ...
Chandra sekhar kode
Jun 9, 2016 at 2:01 pm
Jun 9, 2016 at 2:01 pm -
Hi, hakkers! I have a distributed app that uses `akka-persistence` and `akka-sharding`. For some of my shard coordinators I use `remember entities` feature. I heard (from Bonér or Kuhn, can't say for ...
Denis Mikhaylov
Jun 9, 2016 at 7:48 am
Jun 10, 2016 at 6:30 pm -
Sorry but i have another newbie question. I have an actor that uses cluster sharding. There are potentially millions of these in the sytem concurrently and they maintain some state. At some point I ...
Kraythe
Jun 8, 2016 at 4:10 pm
Jun 10, 2016 at 7:38 pm -
Hello, I would like to configure my websocket client connection to work on 2-way communication, but I have problems with that. My code : Sink and Source flow creation: def myFlow(): Flow[String, ...
Marcelo Alves
Jun 7, 2016 at 8:43 pm
Jun 9, 2016 at 2:01 pm -
I am currently adding Akka to our existing system that currently does distributed programming with Executors in Hazelcast. Obviously he executor system is not scaling so I am currently working on how ...
Kraythe
Jun 7, 2016 at 3:49 pm
Jun 9, 2016 at 6:49 pm -
Hi @ all This question is a duplication of this http://stackoverflow.com/questions/37659421/what-is-the-best-way-to-combine-akka-http-flow-in-a-scala-stream-flow stack overflow questions. I would ...
Ivan Morozov
Jun 7, 2016 at 9:12 am
Jun 9, 2016 at 10:09 am -
I have a graph that is leaking http connections from an Akka-Http Superpool when the graph fails. The general shape of the graph is: A ~ B ~ C ~ D ~ E ~ F The stage actions are: A emits HttpRequests ...
Spencer Stejskal
Jun 6, 2016 at 5:23 pm
Jun 15, 2016 at 6:33 pm -
I have an actor that I would like to use cluster sharing for but the thing is that the actor will restore its state from a database in the event of migration and so on. So there is no need to journal ...
Kraythe
Jun 6, 2016 at 5:19 pm
Jun 9, 2016 at 9:57 am -
I have created a very basic Restful service in Spary. Locally it is all working fine. But when I deployed it onto the server (2 core), I am seeing CPU usage at 100%. The usage peaks to 100% for a few ...
Abhishek jain
Jun 6, 2016 at 4:45 pm
Jun 6, 2016 at 5:25 pm -
I have a Class that have one single filed which is a java HashMap. The class looks like case class Myclass(val map: java.util.Map[String, AnfRef]), And I want to handle instances of this class in my ...
Origin Jing
Jun 6, 2016 at 9:29 am
Jun 9, 2016 at 9:49 am -
I have the following use case: I need to get a token via an initial Remote API web call and then use that token for all subsequent API calls. Simple enough. Here is the chunk of code however that ...
Gary Hewett
Jun 5, 2016 at 5:08 pm
Jun 9, 2016 at 9:50 am -
Hello, I'm noob on Scala and Akka development. So, I need to implement a websocket client communication and my dificuty are on outgoing messages. I dont really know how to do that using akka ...
Marcelo Alves
Jun 4, 2016 at 9:35 am
Jun 5, 2016 at 9:40 pm -
To configure cassandra for akka in java using environment variables I am writing the following code which is throwing the error String contactPoints = "cassandra-journal.contact-points=" + ...
Amruta
Jun 3, 2016 at 7:17 pm
Jun 3, 2016 at 10:01 pm -
Dear hakkers, we—the Akka committers—are proud to announce a new patch release of Akka 2.4. This release contains a number of minor improvements and fixes spread out across many of the Akka modules ...
Johan Andrén
Jun 3, 2016 at 3:52 pm
Jun 4, 2016 at 11:45 am -
Hello, I am building a service which uses Akka Http Client to contact another service and return a Future. The current architecture result in materializing a stream repeatedly like that: val source = ...
Edmondo Porcu
Jun 3, 2016 at 7:44 am
Jun 3, 2016 at 7:44 am -
I am sorry I have been blitzing the group with questions but I have a rather snug deadline so I hope you will excuse the flurry. I currently have Hazelcast integrated into my system as a distributed ...
Kraythe
Jun 3, 2016 at 5:50 am
Jun 3, 2016 at 5:50 am -
Greetings, I am wiring together some actors using distributed pub-sub. Basically I have actors that are broadcasting their state change. These updates will be in the millions and be received by ...
Kraythe
Jun 2, 2016 at 7:09 pm
Jun 2, 2016 at 10:34 pm -
Thanks Mark. But why leader can not remove down node at last. In my experience, this node first mark 102 node unreachable, after few seconds, this node mark another node 100 unreachable. Then,this ...
Weed
Jun 2, 2016 at 2:39 pm
Jun 2, 2016 at 2:39 pm -
Hi all, I'm creating a small project using Akka Http and I'm creating an Actor System for it, as per documentation. In this project, I'm also using another lib (rediscala) that requires an Actor ...
Luciano Molinari
Jun 2, 2016 at 10:33 am
Jun 2, 2016 at 12:41 pm -
Hi, I'm using akka http for file uploading as bellow: formFields('json.as[String]) { json = uploadedFile("file") { ... } And it works fine if I upload one file at a time. But I want to upload ...
Leo Wolf
Jun 2, 2016 at 6:25 am
Jun 2, 2016 at 10:03 am -
**** Paper submission deadline extended: 10 June, 2016 **** Apologies for any duplicates you may receive. CALL FOR PAPERS =============== Fifteenth ACM SIGPLAN Erlang Workshop ...
Erlang Workshop
Jun 1, 2016 at 9:38 pm
Jun 1, 2016 at 9:38 pm -
I was working on a supervisor that lazy creates actors based on some key and then will forward messages to that actor. However, it just seems like I am doing something frightfully common. So I was ...
Kraythe
Jun 1, 2016 at 8:39 pm
Jun 2, 2016 at 3:32 pm -
I just started working with akka streams (2.4.6) and slick (3.1.1) in Scala (2.11.7). I'm using Intellij (not sure if that matters but I thought I'd throw it out there). val scanner ...
Marco Rispoli
Jun 1, 2016 at 1:11 pm
Jun 3, 2016 at 6:18 pm -
- low-level-server-side-api.html - - The following are requestHandler methods - - a Flow[HttpRequest, HttpResponse, _] for handleWith, - a function HttpRequest = HttpResponse for ...
RamuR
Jun 1, 2016 at 8:28 am
Jun 2, 2016 at 5:07 am -
Hi, We have a project where we need to talk to hadoop/hdfs to download some files from it. This requires that we have protobuf 2.5.0. This is a new cluster for us and before this the older hadoop ...
Mohnish Kodnani
Jun 1, 2016 at 7:48 am
Jun 1, 2016 at 9:45 am -
the log is follow: 2016-05-31 07:40:54,053 | WARN | lt-dispatcher-16 | ClusterCoreDaemon [akka.tcp://opendaylight-cluster-data@192.168.23.240:2550] - Marking node(s) as UNREACHABLE [Member(address = ...
281725287
Jun 1, 2016 at 7:47 am
Jun 2, 2016 at 8:40 am -
I am seeking advice from those more experienced about some ideas for dealing with dependent processing. The use case is simple though I have to be a bit coy because of NDAs. I have some ideas myself ...
Kraythe
May 31, 2016 at 4:31 pm
Jun 2, 2016 at 5:40 pm -
Hi, I looked into many nice Examples with Akka Websockets (like https://markatta.com/codemonkey/blog/2016/04/18/chat-with-akka-http-websockets/), but sadly the used flows only handle strict ...
Qux
May 31, 2016 at 4:28 pm
May 31, 2016 at 8:06 pm
Group Overview
group | akka-user |
categories | scala |
discussions | 5,101 |
posts | 22,663 |
users | 2,257 |
website | akka.io |
irc | #akka |
Top users
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)