akka-user@googlegroups.com discussions

0	[akka-user] Akka - TCP - Byte level control

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

0	[akka-user] Akka Http Client not receiving response for all requests

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

1	[akka-user] Akka - Accessing cache using Actor .tell() and make decision based on the cache value

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

0	[akka-user] Cluster Sharding(2.4, Java/Groovy)-how to avoid a rebalance during a rolling release?

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

0	[akka-user] Akka Http Websocket Testing

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

1	[akka-user] How to use custom HTTP methods in akka-http

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

0	[akka-user] AbstractPersistentActor recover

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

1	[akka-user] routes using akka-http

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

0	[akka-user] akka-streams behavior for "infinite" data source with ActorPublisher

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

1	[akka-user] How to use play-ws in akka-http?

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

7	[akka-user] Do I have to shutdown AKKA system after each execution

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

2	[akka-user] how to integration akka with spring

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

3	[akka-user] [Akka 2.4.7] + [Play 2.5] Inject Serialization Bindings Config Programmatically??

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

1	[akka-user] Restarting a stream with a bursty Source

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

0	[akka-user] how to reuse previous SourceQueue for new websocket connection

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

6	[akka-user] Subclassing Shard Region Actor a good idea?

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

0	[akka-user] Newbie question: connecting to read journal in preStart

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

13	[akka-user] Runtime issue with Cluster Sharding.

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

23	[akka-user] ANNOUNCE: New Remoting Milestone 2

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

0	[akka-user] Message ordering after Akka actor restart

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

13	[akka-user] Akka Spring integration seems to slowly leak memory

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

1	[akka-user] Trying to load configurations

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

0	[akka-user] How to listen websocket server close events using akka-http websocket client

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

5	[akka-user] How to handle zero (almost) downtime deployments of sharded persistent system.

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

8	[akka-user] Another Newbie Question -- Sending message to Millions of Cluster sharded actors.

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

3	[akka-user] two-way on websocket

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

6	[akka-user] Newbie question about storing ActorRef in a member variable

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

1	[akka-user] Best practice to combine akka-http and akka-stream flows

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

2	[akka-user] akka-http superpool leaks connections on graph failure

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

2	[akka-user] Cluster sharing without persistence? How to relay entity id to props?

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

1	[akka-user] Akka/Spray CPU usage is 100%

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

1	[akka-user] How to create a akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller for a class like case class Myclass(val map: java.uitl.Map[String, AnyRef])

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

2	[akka-user] Is there any reason(s) why Await inside an Actor would be different in (Play's) Development mode versus Production mode?

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

3	[akka-user] Akka webscoket client support - outgoing messages

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

1	[akka-user] Akka Config throwing reserved character error

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

4	[akka-user] ANNOUNCE: Akka 2.4.7 Released

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

0	[akka-user] Stateless service with repeated stream materialization or actor?

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

0	[akka-user] Cluster Sharding + Hazelcast: Possible to dictate host for shard?

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

4	[akka-user] Considerations when pushing millions of messages through DistributedPubSub?

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

0	[akka-user] 回复： In akka cluster, why a node which state is down can be makesreachable

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

2	[akka-user] Using Akka HTTP and another lib that also requires an ActorSystem

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

1	[akka-user] akka directive for uploading multiple files

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

0	[akka-user] [ANN] Deadline extended! Erlang Workshop 2016

**** 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

7	[akka-user] Am I Reinventing the Wheel?

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

3	[akka-user] Scala - fromPublisher is not a member of object akka.stream.scaladsl.Source

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

2	[akka-user] handleWithSyncHandler, handleWith, handleWithAsyncHandler

- 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

2	[akka-user] spray cache and akka http

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

1	[akka-user] [akka-cluster]: The node State is down, Why leader do not remve it.

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

10	[akka-user] Dependent Processing with Millions of Records without Backlogging?

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

2	[akka-user] Akka Websocket Strict vs non Streamed

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	akka-user @
categories	scala
discussions	5,101
posts	22,663
users	2,257
website	akka.io
irc	#akka

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

Scala > akka-user

Search Discussions

5,101 discussions - 22,663 posts

Top users

Content

People

Support

Translate