Re: [akka-user] testing akka cluster on Blue Waters @ NCSA

On Mon, Nov 24, 2014 at 1:32 AM, Nidhi wrote: > Hello all, we are working on a course project to simulate twitter server > and twitter users and test the server for the load it can handle. We have > users on one system (with one client master and around 10,000 user actors) > and server on another

Re: [akka-user] AKKA cluster remoting taking time

Yes now I am shifted to use kryo but its not working. below is my applicatin .conf kindly help because m struck on kryo :( akka { extensions = ["com.romix.akka.serialization.kryo.KryoSerializationExtension$"] event-handlers = ["akka.event.slf4j.Slf4jEventHandler","com.typesafe.atmos.trace.Slf4jT

Re: [akka-user] testing akka cluster on Blue Waters @ NCSA

Hello all, we are working on a course project to simulate twitter server and twitter users and test the server for the load it can handle. We have users on one system (with one client master and around 10,000 user actors) and server on another machine(one master and 1000 worker actors) to resolv

[akka-user] remote akka problem - not able to communicate

Dear All, I have some problem with remote akka. I'm trying to create one akka remote actor node and connect it from a different machine. I opened the port 2551,2552,2553 ports of both the machines. But after creating the remote actor in one machine I'm not able to access it from the other ma

Re: [akka-user] AKKA KRYO causing cluster node unregister

Hi, I have tried with `default` id generation strategy Below are the logs that i am getting. It's a null pointer exception but I am sending only hashmap and a long variable inside the RecordNewMessage 2014-11-25 12:37:56 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://Cluster

Re: [akka-user] AKKA KRYO causing cluster node unregister

Hi, Yes I am using the same configuration of application.conf in both nodes. I have tried with 'default' id generation strategy but againg receiving node becomes unrechable. Now i have created the small application with two nodes one sending and one receiving kryo logs is running on bot

Re: [akka-user] Akka Streams documentation and examples

There is no reference documentation yet. You find API documentation here: http://doc.akka.io/api/akka-stream-and-http-experimental/0.11/ http://doc.akka.io/japi/akka-stream-and-http-experimental/0.11/ and getting started Activator templates: http://typesafe.com/activator/template/akka-stream-

Re: [akka-user] Akka Streams documentation and examples

I tried this, but cannot find anything there. http://doc.akka.io/docs/akka-stream-and-http-experimental/0.11/scala.html?_ga=1.67564625.1938417986.1393726085 On Tuesday, November 25, 2014 1:09:46 AM UTC-5, Piyush Mishra wrote: > > Visit akka.io > > Piyush Mishra > *Blog*

Re: [akka-user] Akka Streams documentation and examples

Visit akka.io Piyush Mishra *Blog* | *LinkedIn * Skype : piyush.mishra275 Hangout :piyushmishra889 Mobile : +91-8860876875 On Tue, Nov 25, 2014 at 11:38 AM, Soumya Simanta wrote: > Can someone point to documentati

[akka-user] Akka Streams documentation and examples

Can someone point to documentation and examples for Akka Streams. Thanks -Soumya -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.

[akka-user] type mismatch when using pipeTo pattern in Route while parsing entity

I have the following routes def routes: Route = path(Segment) { cmd => get { requestContext => val request = CMD(command = cmd, params = Nil: List[String]) val responder = createResponder(requestContext) batcApi.ask(request).pipeTo(responder) } ~ post { requ

Re: [akka-user] Akka clusterclient Association Error / ClassNotFoundException when serialising response

Hi Martynas, Yes the class (without the dollar sign) is in the classpath. It is actually in another project that i made to depends on the frontend and backend On Thursday, November 13, 2014 6:35:08 PM UTC+7, Martynas Mickevičius wrote: > > Hi Hengky, > > could you make sure that Acknowledged$ cl

Re: [akka-user] Reactive actor-actor communication

> By the way - isn't dropping demand messages a problem also in the current >>> remote-streams implementation? >>> >> There is no remote akka streams yet. > If you mean tcp then the demand is just generated "by the socket" - not > through passing tokens over the network. > So as I understand b

Re: [akka-user] Using Future with Actor Selection

Yeah by Future request I mean ask pattern. Well the configuration of my actors is as following. - Create Actor System - Create Master and Send an Object for processing. - Create Future and ask the Result form the Master Master will create various workers and then aggregate the result from t

Re: [akka-user] Confusion about durable mailboxes superseded by akka-persistence?

You don’t remove things in an event sourced application. You mark as deleted. A B C DEL-A DEL-B D DEL-C — konrad On 24 November 2014 at 14:08:37, Karthik Chandraraj (ckarthi...@gmail.com) wrote: The reason why I used snapshot instead of persist message is, I need to remove the message from th

Re: [akka-user] Confusion about durable mailboxes superseded by akka-persistence?

The reason why I used snapshot instead of persist message is, I need to remove the message from the queue on processing it. In case of snapshot, I will just remove it from the linked queue and save the snapshot. How can I achieve the same using persist message? For ex: Consider I have received t

Re: [akka-user] Reactive actor-actor communication

> > sorry it took my a while to get to this email - been consuming the "least > responded / oldest" email from the list throughout the week, not sure it > this worked well or not yet... :-) > no problem, it's open-source, no SLAs ;) > By the way - isn't dropping demand messages a problem also

Re: [akka-user] Save 2 snapshots at the same time?

A surprising way to use the Journal I’d say but yeah, it would work. — k  On 24 November 2014 at 12:23:35, Soumya Simanta (soumya.sima...@gmail.com) wrote: On Monday, November 24, 2014 3:29:33 AM UTC-5, Konrad Malawski wrote: On Mon, Nov 24, 2014 at 5:50 AM, Soumya Simanta wrote: Also, does

Re: [akka-user] Save 2 snapshots at the same time?

On Monday, November 24, 2014 3:29:33 AM UTC-5, Konrad Malawski wrote: > > > On Mon, Nov 24, 2014 at 5:50 AM, Soumya Simanta > wrote: > >> Also, doesn't snapshotting every message effectively means now your >> snapshot is your log/journal ? >> Please correct me if that is not correct. >> > > Th

Re: [akka-user] Using Future with Actor Selection

By "future request" you mean ask (?) pattern , right? If so, why do you want to complete the future by other means than replying to the original message? On Mon, Nov 24, 2014 at 12:37 PM, Syd Gillani wrote: > Hi,

[akka-user] Using Future with Actor Selection

Hi, I was going through the Akka actorselection documents and as it describes that you can select and actor and send a reply to it. For instance getContext().system().actorSelection("/actor/a").tell(result, getContext().self()); However, I was wondering if its possible in case of future as wel

Re: [akka-user] Re: Akka Persistence and Kryo serialization

Thank you for the suggestions, unfortunately no, setting it to default didn't seem to make any difference On Friday, November 21, 2014 2:54:28 PM UTC, Konrad Malawski wrote: > > Hey guys, > I just skimmed it, but it seems Evgeniy's suggestion should help. > If you want it to be explicit you'd hav

Re: [akka-user] Save 2 snapshots at the same time?

On Mon, Nov 24, 2014 at 5:50 AM, Soumya Simanta wrote: > Also, doesn't snapshotting every message effectively means now your > snapshot is your log/journal ? > Please correct me if that is not correct. > That's more of a naming thing I'd say, but yes. -- Cheers, Konrad 'ktoso' Malawski hAkker