Re: [akka-user] Testing Terminated

Sigh! Looks like using reflection doesn’t work, as Akka treats Terminated specially (DeathWatch.receivedTerminated). Is there support from TestKit? Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keyb

[akka-user] Re: Working with file system (io)

Hello, Maybe this blog article, and the accompanying github repo can be helpful: http://blog.florian-hopf.de/2012/08/getting-rid-of-synchronized-using-akka.html especially the Master actor

[akka-user] Re: Akka java newbie : Managing different routess within an actor

I would separate the parenting into two actors, one UdpProcessor and one ObjectProcessor, and then introduce a single Processor parent to those two. This would basically take eliminate the whole problem and make each part simpler. If you absolutely want to keep the two concerns in the same acto

Re: [akka-user] How do I create an Unmarshaller / Marshaller in java?

Sorry, this must have slipped through. While I cannot currently offer intelligent advice, may I ask that you create a ticket so that either the API or the documentation shall be improved? Thanks, Roland > 27 jul 2015 kl. 11:00 skrev john.vie...@gmail.com: > > or am I supposed to use Marshalle

Re: [akka-user] Akka interoperability with Akka.net ?

Hi Alex, > 27 jul 2015 kl. 15:10 skrev Alexandre Vermeerbergen > : > > Hello, > > > I’m working on a project for which Akka seems to be a nice match, except > that I finally found a huge showstopper. > > > Indeed, in our project, most business logic is written in Java, but a few > porti

Re: [akka-user] memory issue in akka application

No matter which logging solution you choose, if you try to log more messages than it can handle then something has to give: either the system’s message queues grow out of bounds or you start dropping log messages. If you use a bounded mailbox then make sure to set the wait time to 0s because oth

[akka-user] ClusterClient dropping messages

I am using Cluster Client , I am sending 75000 messages in span of 5 mins using this,but cluster client is dropping some 300 messages. Its spray,akka set up. Running on single 4core,8GB Ram machine. By dropping messages I mean, its not going to receivingActor. Following is the ClusterClient

[akka-user] Re: Is this the correct flow to retrieve bytes from an HttpResponse?

i think I need to wait for https://github.com/akka/akka/issues/15089 Am Donnerstag, 30. Juli 2015 08:18:18 UTC+2 schrieb john@gmail.com: > > // this is part of a BidiFlow > > FlowShape, RequestResult>, > Tuple2> > bottom = > b.graph(Flow., Object>>empty(). > mapAs

Re: [akka-user] Send messages to ShardRegion from another JVM

Using the proxy is the right approach. You don't know where the end destination is located anyway so even if you send it directly to a shard region on another node it will probably forward it to anyway. /Patrik On Mon, Aug 3, 2015 at 4:59 PM, Yifei wrote: > Hi, > > I would like to start differe

[akka-user] Ask Pattern vs Micro Actors?

I am looking at how I can hook up an actor system with synchronous controller code. Essentially there are REST endpoints and other methods that have to make certain calls and then wait for the response for going on. Essentially bridging the actor system to a non-actor system. I know I can use t

[akka-user] Re: Ask Pattern vs Micro Actors?

http://letitcrash.com/post/96078609472/ask-tell-and-per-request-actors Maybe this will help answer your question. Actors are cheap, but not free. There are cases where using an actor-per-request pattern has more benefits than performance detractors. Per method call? I think that would depend

Re: [akka-user] memory issue in akka application

If you'd like to handle this in logback land and not deal with altering akka's logging strategy, you can also configure logback to work in bounded space and drop overflows as well. Take a look at logback's AsyncAppender. http://logback.qos.ch/manual/appenders.html You'll configure your logback

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

I see this issue happen whenever AWS has a network hiccup. I have a multi-node cluster behind a LB and akka cluster sharding along with akka persistence writing to a Dynamo journal. I'm currently on akka 2.3.11, which means the same shared Dynamo table used to store my persistent actors is al

Re: [akka-user] Testing Terminated

There is no support in testkit for creating fake Terminated messages. That would probably be a nice addition. I guess you have already explored and rejected the option to actually stop the watched actor in the test. /Patrik On Tue, Aug 4, 2015 at 9:27 AM, Heiko Seeberger wrote: > Sigh! Looks l

Re: [akka-user] Re: Ask Pattern vs Micro Actors?

Yeah, that's my reaction as well. ask() basically *is* a micro-Actor, and is highly optimized for the purpose. And while I can believe that it's suboptimal for Java code, it's kind of hard to imagine anything that's easier to use on the Scala side, since Futures allow you to compose complex multi

[akka-user] Pending Mailbox on Actor Failover in Cluster

When using Akka Clustering, if a JVM crashes, what happens to the pending messages in the actors on the failed system? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search

Re: [akka-user] Re: Ask Pattern vs Micro Actors?

Well the problem is that translating the whole framework into Scala just isn't going to happen. Battles have to be picked. However, the inability to use lambdas with Scala futures makes it VERY verbose to use with Java and error prone. Since I have to sell this on ease of use it makes it hard fo

[akka-user] Re: How do I create an Unmarshaller / Marshaller in java?

Hi John, On Monday, July 27, 2015 at 11:00:57 AM UTC+2, john@gmail.com wrote: > > or am I supposed to use Marshallers.toEntity() but this seems quite a lot > of work > Yes, to create custom marshallers you would need to use one of the methods in `Marshallers`, to create custom unmarshaller

Re: [akka-user] Testing Terminated

> On 04 Aug 2015, at 22:52, Patrik Nordwall wrote: > > There is no support in testkit for creating fake Terminated messages. That > would probably be a nice addition. > > I guess you have already explored and rejected the option to actually stop > the watched actor in the test. Sort of. I’m i