Re: [akka-user] How to start Actor in separate JVM on same machine?

It is possible to start an actor in another remote ActorSystem, by using the remote deployment feature. See this section of the documentation: http://doc.akka.io/docs/akka/2.3.11/java/remoting.html#Creating_Actors_Remotely You must still start the JVM and the ActorSystem separately. An alternativ

[akka-user] O'Reilly Scala books discount week

Hi gang, quick heads up: O'Reilly is offering 50% off four Scala books this week at http://shop.oreilly.com/category/deals/scala.do?code=WKSCLA . Apparently this deal is only for the four on that page, which I found out after calling

[akka-user] Akka and Mesos: Will it blend?

Hi all, Just curious if anyone on the list has tried to blend Akka and Mesos at a level that is more granular than the JVM. For those that have heard about it but don't know much about it's core, Mesos is using kernel cgroups to provide ultra light weight virtualization with very low overhead f

Re: [akka-user] Sharding problem when restarting Cluster

It's been a while! But just for reference, Patrik investigated my issue at the time and we came to the conclusion I had accidentally created two clusters writing to the same database (I had not set up my seed nodes in a resilient way as I was only doing a prototype). Once I fixed this the issue was

Re: [akka-user] Sharding problem when restarting Cluster

You're welcome. Let me know if you see same problem with Cassandra, then I will give it more attention. /Patrik ons 17 jun 2015 kl. 18:56 skrev GG : > Alright. We'll give Cassandra a try. Thanks for the help Patrik. > > On Tuesday, June 16, 2015 at 1:05:39 PM UTC-7, Patrik Nordwall wrote: >> >> >

Re: [akka-user] Re: Akka 2.4 milestones, RC and final release ETAs?

plus,I think it would be great that i could create a dispatcher from the eventloop,and using it for the actor creating,but currently it's impossible. and for the flow control and thread usage,you could reuse the event loop ,control the register and deregister,control the read and write and chang

Re: [akka-user] Re: Akka 2.4 milestones, RC and final release ETAs?

I don't have a dedicated dispatcher for the proxy actor,and for the server and client side pools,in fact it's event loop group,a more nice one is using reflection,create it via provider,then you have all the control ,but I think the default one is good,and the code there,is not that good,more of

[akka-user] Apache Camel vs Apache Camel + Akka

Good day! I have a running Apache Camel application which currently does the following: - It has a custom component which writes to a MongoDB system using the ReactiveMongo library. - Routes to process messages from RabbitMQ to a SOAP WS and forward the responses to a RESTful WS

[akka-user] Re: TCP Actors: Sometimes client request is spitted in two pars

you need a frame based codec. LV,L->Length,V->Value 在 2015年6月16日星期二 UTC+8下午7:17:26，Dmitrii Galagaev写道： > > I am using TCP(http://doc.akka.io/docs/akka/snapshot/java/io-tcp.html) > actor as entry point to my java application: > > public SupervisorActor() { > receive(ReceiveBuilder. >

Re: [akka-user] Sharding problem when restarting Cluster

Alright. We'll give Cassandra a try. Thanks for the help Patrik. On Tuesday, June 16, 2015 at 1:05:39 PM UTC-7, Patrik Nordwall wrote: > > > > On Tue, Jun 16, 2015 at 7:44 PM, GG > > wrote: > > Patrick, > > Thanks for your reply. We are using leveldb in a cluster system following > the SharedLev

Re: [akka-user] Re: CORS Support Akka-http

I'll get my colleague to post something He did the work On 17 Jun 2015 15:34, "Mariano Treb" wrote: > I am having the same problem!!! How did you solved it? I have been working > for days and I cant find any good solution. > > El martes, 10 de marzo de 2015, 18:48:09 (UTC+1), Tim Pigden escribió:

[akka-user] Re: [akka-streams] Can I have an actorRef from a Source without consuming Element

The "old way" is still working, so I can fix my problem like that : val actorRef = system.actorOf(Props[TweetPublisher]) val pub = ActorPublisher[TweetInfo](actorRef) val source = Source(pub) Le mercredi 17 juin 2015 14:24:55 UTC+2, Loïc Descotte a écrit : > > Hi, > > I have an ActorPublisher an

Re: [akka-user] Extracting multiple form values with the same name

Thanks for your feedbacks. Le mardi 16 juin 2015 11:58:09 UTC+2, Martynas Mickevičius a écrit : > > Also it seems there is already a PR to add this functionality to > akka-http: https://github.com/akka/akka/pull/17107 > > On Mon, Jun 15, 2015 at 10:20 PM, Martynas Mickevičius < > martynas.m...@t

[akka-user] Re: CORS Support Akka-http

I am having the same problem!!! How did you solved it? I have been working for days and I cant find any good solution. El martes, 10 de marzo de 2015, 18:48:09 (UTC+1), Tim Pigden escribió: > > This thread may help: > > https://groups.google.com/forum/#!searchin/akka-user/cors/akka-user/msJfSkHDC

Re: [akka-user] akka-stream: How to map aggregation (fold) and periodic flush to stream ("scanWithin")

On Wed, Jun 17, 2015 at 3:58 PM, Roland Kuhn wrote: > Hi Endre, > > one issue here is that conflate does not allow you to keep state for the > “next round”, > True, but then a DetachedState is probably the best option. There is one example in the cookbook that just repeats the last element seen,

Re: [akka-user] akka-stream: How to map aggregation (fold) and periodic flush to stream ("scanWithin")

Hi Endre, one issue here is that conflate does not allow you to keep state for the “next round”, so scanWithin is indeed a different kind of operation; or did you mean to .scan(...).conflate(...).zip(TickSource)? Regards, Roland > 17 jun 2015 kl. 12:53 skrev Endre Varga : > > Hi Elmar, > >

[akka-user] [akka-streams] Can I have an actorRef from a Source without consuming Element

Hi, I have an ActorPublisher and I'm building a source from it : val source = Source.actorPublisher[TweetInfo](Props[TweetPublisher]) I need to send new elements into this source dynamically so I want an actor ref. On the last documentation (1.0-RC3), I've seen that I can do it this way : val

Re: [akka-user] Average Message transfer time

I would guess that you are filling up the tcp buffer, and then Akka will back-off and start buffering the messages. Maybe you can see this log message: log.warning("[{}] buffered messages in EndpointWriter for [{}]. " + "You should probably implement flow control to avoid flo

Re: [akka-user] [akka-http]idle-timeout config doesn't seem to take any effect

I think this has reported here https://github.com/akka/akka/issues/17732 and maybe also https://github.com/akka/akka/issues/16597 /Patrik On Sun, Jun 14, 2015 at 3:51 AM, Konrad Cichocki wrote: > Hello guys I have problems with using akka-http in my application. I have > a function that is down

Re: [akka-user] Re: AKKA Pool of workers

Using a router pool is the easiest way to create a worker pool of the same actor type. If you need better flow control the link that Idar shared is excellent. /Patrik On Tue, Jun 16, 2015 at 11:41 PM, Idar Borlaug wrote: > Have you read t

Re: [akka-user] How to control excessive logging from LocalActorRefprovider

I'm interested in where all those resolve calls come from, because it could be a performance issue. It could be deserialization of ActorRef. Yesterday I removed storage of the sender ActorRef in persistent events, which typically would result in such things when persistent actors replay the event

[akka-user] Re: The "all roles" developer with IntelliJ, Java and Maven

I'm still in the process of learning Scala, remember atm the project is written in Java 8, to be more provider dependent we are thinking to use Akka HTTP/Streams combined with AngularJS for such purpose. About SBT, I'm not denying it is better than Maven but there was a strong time constrain so

Re: [akka-user] akka-stream: How to map aggregation (fold) and periodic flush to stream ("scanWithin")

Hi Elmar, You can try the "conflate" operator, and then use a ZipWith junction in a graph to wire it together with a tick source. You should read this section of the documentation for more (and important) details: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC3/scala/stream-rate.

Re: [akka-user] How to control excessive logging from LocalActorRefprovider

Since the log source is specified directly as a String by the LocalActorRefProvider the originating class name is «akka.event.DummyClassForStringSources». The reason is that this LogAdapter needs to be initialized before the ActorSystem is up and running; we could potentially use LogSource.from

Re: [akka-user] Re: Messages get lost in ActorPublisher

When you create a materializer with `ActorFlowMaterializer()` inside an actor the flow will run as a child actor and therefore be bound to the lifecycle of the enclosing actor. There is an `implicit context: ActorRefFactory` parameter. However, I see that you are actually scoping it to the system

Re: [akka-user] Re: The "all roles" developer with IntelliJ, Java and Maven

Thanks for sharing your experience, Guido. On Wed, Jun 17, 2015 at 10:45 AM, Anton Kulaga wrote: > Why Maven? SBT is much better and flexible. Also, if you will decide to > add some scalajs code to frontend you will have to move to sbt anyway as > maven currently does not support scalajs > > On

[akka-user] Re: The "all roles" developer with IntelliJ, Java and Maven

Why Maven? SBT is much better and flexible. Also, if you will decide to add some scalajs code to frontend you will have to move to sbt anyway as maven currently does not support scalajs On Tuesday, June 16, 2015 at 11:14:53 PM UTC+3, Guido Medina wrote: > > Hi, > > This is not exactly a question