[akka-user] Re: Strange java.lang.VerifyError with ActorSystem initialization

I just experienced the same issue this week. Turns out I had an older version of the newrelic java agent installed which caused the issue. I updated the newrelic java agent to the latest version (as of this writing ver 3.41.0) and that fixed the issue. Thanks to this thread I could stop

[akka-user] SMACK Stack - Benefit of Akka Cluster?

Hey everyone, I'm evaluating whether to use the SMACK stack as part of our data pipeline, as demonstrated in this reference app: https://github.com/killrweather/killrweather I don't want to introduce unnecessary complexity in our stack unless it gives enough bang for the buck. From that

Re: [akka-user] Akka design question

Justin, Once again, thank you so very much for your input. It is much appreciated. Now we need to do our homework and build out a strawman Thanks again, -- Chris On Tuesday, December 13, 2016 at 7:38:51 AM UTC-6, Justin du coeur wrote: > > On Mon, Dec 12, 2016 at 11:57 PM, Chris Berry

Re: [akka-user] Akka design question

, memcached -- how would you model something like that in this scenario? Would you simply create a child CacheActor that indirectly handles that interaction. Again, thank you so much for taking your time to answer my questions. Cheers, -- Chris On Monday, December 12, 2016 at 5:09:35 PM UTC-6

[akka-user] Akka design question

to the Rates computation. Clearly that must happen in parallel? - How does one cleanly share the cached RateInfo across the Actors? Sorry if these questions are too broad. I am a total newbie. I am looking to start a POC, and need a place to begin. Thanks much, -- Chris

Re: [akka-user] Cluster Metrics on Windows

I've created the issue here: https://github.com/akka/akka/issues/21240 Chris On Sun, Aug 21, 2016 at 3:28 AM, Endre Varga <endre.va...@lightbend.com> wrote: > Hi Chris, > > Thank you for all this, very valuable information! Can you please file a > ticket on the repo for f

Re: [akka-user] Cluster Metrics on Windows

Someone responded to me in the hyperic sigar issue. Apparently this is implemented in the Boundary fork of sigar: https://github.com/boundary/sigar On Sat, Aug 20, 2016 at 4:29 PM, Chris Van Vranken < cessationoft...@gmail.com> wrote: > In the Sigar repository there is a comment in fi

Re: [akka-user] Cluster Metrics on Windows

at, Aug 20, 2016 at 4:06 PM, Chris Van Vranken < cessationoft...@gmail.com> wrote: > I found an issue <https://github.com/hyperic/sigar/issues/72> for this > listed in the hyperic/sigar github repo. > > On Sat, Aug 20, 2016 at 3:12 PM, Chris Van Vranken < > cessat

Re: [akka-user] Cluster Metrics on Windows

I found an issue <https://github.com/hyperic/sigar/issues/72> for this listed in the hyperic/sigar github repo. On Sat, Aug 20, 2016 at 3:12 PM, Chris Van Vranken < cessationoft...@gmail.com> wrote: > I found the problem: > > In file: akka-cluster-metrics/src/main/scala/ak

Re: [akka-user] Cluster Metrics on Windows

I bet akka.cluster.metrics.native-library-extract-folder isn't configured properly. On Sat, Aug 20, 2016 at 1:00 PM, Chris Van Vranken < cessationoft...@gmail.com> wrote: > One thing that I've noticed is it seems to startup as JMX. But then it > subsequently provisions S

Re: [akka-user] Cluster Metrics on Windows

One thing that I've noticed is it seems to startup as JMX. But then it subsequently provisions Sigar. Though the provision is logged as an error message. The log output looks like this: > runMain sample.cluster.factorial.FactorialApp [warn] Scala version was updated by one of library

Re: [akka-user] Cluster Metrics on Windows

Though sigar is the collector I would like to be able to use. On Aug 20, 2016 11:09 AM, "Chris Van Vranken" <cessationoft...@gmail.com> wrote: > I have tried both of them with the same result on Windows. On Ubuntu I > have only tried sigar. > > On Aug 20, 2016 4:26

Re: [akka-user] Cluster Metrics on Windows

etrics. I am using the factorial example located at: http://www.lightbend.com/activator/template/akka-sample-cluster-scala. And I am running it in sbt with the following command "runMain sample.cluster.factorial.FactorialApp". Is there something I need to do to get this to

[akka-user] Re: ConductR sandbox linking to another container

Hey Christopher. Thanks for getting back to me. Glad to hear that you have this use case on your road map. In the mean time, I will use the -e option workaround that you suggested. Thanks again. On Monday, August 15, 2016 at 4:04:10 AM UTC-4, Christopher Hunt wrote: > > Hi

[akka-user] ConductR sandbox linking to another container

I don't know of any ConductR user group or forum out there, so I am asking here. I am playing around with the ConductR sandbox on my Mac and I want to be able to have my 3 ConductR nodes communicate with Cassandra which is running in another local container. Usually, this can be accomplished

Re: [akka-user] Akka create two Tcp Connections with the same port

and those addresses belong to the system you run the akka > application on. > > -- > Johan > > On Thu, Jul 14, 2016 at 3:08 PM, Chris Stewart <stewart@gmail.com > > wrote: > >> So just to make sure I understand you, I NEED to create this virtual >

Re: [akka-user] Akka create two Tcp Connections with the same port

l only be possible if the hosts resolve to different IP-addresses > on the machine they are run on. For example you could create a virtual > interface with a separate IP address for one of the hostnames. > > -- > Johan > > On Mon, Jul 11, 2016 at 9:12 PM, Chris Stewart <st

[akka-user] Akka create two Tcp Connections with the same port

Hi, as the title says i'm trying to create 2 tcp connections from the same port Here is the stackoverflow question: https://stackoverflow.com/questions/38314437/akka-create-two-tcp-connections-with-the-same-port I'm trying to create two tcp connections that are bound to the same port. I'm

[akka-user] Re: Akka Tcp peer to peer architecture instead of client server

AM UTC-5, Chris Stewart wrote: > > Hi all, > > I posted this question to stackoverflow and haven't had any luck with it > being answered there, so I thought I would try here: > > You can see the post here: > https://stackoverflow.com/questions/37818347/akka-tcp-create-p

[akka-user] Akka Tcp peer to peer architecture instead of client server

Hi all, I posted this question to stackoverflow and haven't had any luck with it being answered there, so I thought I would try here: You can see the post here: https://stackoverflow.com/questions/37818347/akka-tcp-create-peer-to-peer-architecture-instead-of-client-server In the current

[akka-user] Handling timeouts when consuming http services via pooled connections

I realized recently that if I add a completionTimeout to a Flow setup to make http requests through a host connection pool that I can wedge the pool when enough (4 for the default config) of these timeouts happen. I believe this is because the entity associated with the eventual response is

Re: [akka-user] Best practice for consuming a Http response entity's data stream

, April 8, 2016 at 9:57:27 AM UTC-4, Chris Baxter wrote: > > None of the out of the box Unmarshallers for json (like SprayJsonSupport) > support parsing in a lazy and streaming way. I did find this repo which > looks promising: > > https://github.com/knutwalke

Re: [akka-user] Best practice for consuming a Http response entity's data stream

to read all of the data into memory, but large responses are not the norm and are more of the exception for us. On Friday, April 8, 2016 at 8:59:10 AM UTC-4, Chris Baxter wrote: > > Thanks for responding Viktor. > > 1) I see the flaw in this design (flatMapConcat) now. If the response i

Re: [akka-user] Best practice for consuming a Http response entity's data stream

there. On Friday, April 8, 2016 at 7:13:51 AM UTC-4, √ wrote: > > > > On Fri, Apr 8, 2016 at 1:06 PM, Chris Baxter <cba...@gmail.com > > wrote: > >> If I want to consume a Http service and then do something with the >> response body, there are a couple of w

[akka-user] Best practice for consuming a Http response entity's data stream

If I want to consume a Http service and then do something with the response body, there are a couple of ways to go about doing that. The two ones that I am trying to decide between are: val f:Future[ByteString] = Source.single(req). via(outgoingConn).

[akka-user] Behavior of akka 2.4.3 with modeled custom headers

So I have some custom modeled headers, with one of them being defined like so: object `X-Access-Token` extends ModeledCustomHeaderCompanion[`X-Access-Token`]{ override val name = "X-Access-Token" override def parse(value:String) = util.Try(`X-Access-Token`(value)) } case class

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

Mar 4, 2016 at 1:26 PM, Chris Baxter <cba...@gmail.com > > wrote: > >> I have noticed a strange issue after we upgraded to akka 2.4.2 that >> appears sporadically but once it rears its ugly head it basically causes >> the server to consume a ton of CPU and w

[akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

I have noticed a strange issue after we upgraded to akka 2.4.2 that appears sporadically but once it rears its ugly head it basically causes the server to consume a ton of CPU and we have to restart. This issue appears to be with the smallest mailbox pool router. It gets hung up in peekNode

Re: [akka-user] Akka Remote via UDP only responds to first client. Timeouts for any others that connect.

still > bound to the 4201 port? The port should be listed in the output of *ss > -ua* command. > > On Thu, Jan 28, 2016 at 8:08 PM, Chris Benninger <chrisbe...@gmail.com > > wrote: > >> Hi guys, >> >> I'm trying to get Akka Remote actors working via UDP. Every

Re: [akka-user] Nginx error when proxying to Akka Http and large response sizes

Issue created, including a code sample to reproduce the issue: https://github.com/akka/akka/issues/19542 On Wednesday, January 20, 2016 at 6:38:50 AM UTC-5, Akka Team wrote: > > Hi Chris, > > This looks like a weird issue to me. The linked issue in aleph might or > might not rea

[akka-user] Nginx error when proxying to Akka Http and large response sizes

We just finished our conversion of all of our rest endpoints from Unfiltered to Akka Http. In doing so, we noticed a strange error when we have our nginx (version 1.6) proxy sitting in front of Akka Http. If the response is a bit large, over say 30K, nginx fails with the following error:

[akka-user] Nginx error when proxying to Akka Http and large response sizes

We just finished our conversion of all of our rest endpoints from Unfiltered to Akka Http. In doing so, we noticed a strange error when we have our nginx (version 1.6) proxy sitting in front of Akka Http. If the response is a bit large, over say 30K, nginx fails with the following error:

Re: [akka-user] Akka Http Parsing of X-Forwarded-For and DNS lookups

AM UTC-5, rkuhn wrote: > > This sounds like a bug, please open a ticket about this and thanks for > noticing! If you want to follow up with a PR that would be even more > awesome :-) > > Regards, > > Roland > > Sent from my iPhone > > On 07 Jan 2016, at 1

Re: [akka-user] Akka-streams TLS-PSK support

Just dug into: http://docs.oracle.com/javase/7/docs/technotes/guides/security/jsse/JSSERefGuide.html and http://docs.oracle.com/javase/7/docs/technotes/guides/security/crypto/CryptoSpec.html I can confirm the issue is that BC does not implement the required JSSE interfaces. If I am to use

[akka-user] Akka-streams TLS-PSK support

d JSSE, so if I'm mistaken with anything here please let me know! Do you guys know how I'd go about implementing this use case using akka-streams? Any help is appreciated - thanks! -Chris -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>&g

Re: [akka-user] Akka-streams TLS-PSK support

text.getInstance(SSLContext.java:236) On Monday, November 16, 2015 at 5:45:51 PM UTC-5, Konrad Malawski wrote: > > Hi Chris, > Jim responded quicker than I managed to; thanks! :-) > > I'll add a bit more positive hints to the above suggestion, > it seems that BouncyCastle does implement

[akka-user] Idle connection handling for non-pooled http connections

Referencing this ticket , I can see that the idle connection/timeout handling is not yet in place when using pooled connections. I added a comment around the behavior of non-pooled outbound connections with timeouts hoping to get a response but

[akka-user] Detecting Quarantined state

search for the actual text *"The remote system has quarantined this system."* within the error to be sure?? Chris -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>

[akka-user] Using CircuitBreaker within outbound Http stream Flow

Are there any additional plans to provide enhancements to the CircuitBreaker to allow it to more tightly integrate into outbound Http stream Flows? Right now we can make use of the current CircuitBreaker with a mapAsync step as the current breaker supports a Future based withCircuitBreaker

[akka-user] Unhandled ResumeReading messages

Recently, I have started seeing an increase in unhandled ResumeReading messages in my actor system. We are using Akka Streams and Akka Http (RC3) for a small number of things and I'm assuming this is coming from Streams/Http. The log message from my custom unhandled message listener looks

[akka-user] Re: Unhandled ResumeReading messages

settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. On Friday, July 10, 2015 at 8:51:54 AM UTC-4, Chris Baxter wrote: Recently, I have started seeing an increase in unhandled ResumeReading messages in my actor system. We are using Akka Streams and Akka Http (RC3

[akka-user] Handling request timeouts with client side http

I know in Spray that had a request-timeout setting that could be used to control when to timeout a request that has sent the request but has yet to receive a response within a specified timeframe. I don't see this setting anywhere in Akka Http. For a single request, I can handle this by

[akka-user] Re: Config for adding the Remote-Address header in Akka Http

Great. I will keep an eye out for RC4 to see if it makes it in there or not. On Thursday, May 28, 2015 at 6:53:51 AM UTC-4, Chris Baxter wrote: I noticed there is a setting (akka.http.server.remote-address-header) that can be turned to on that should automatically add the Remote-Address

[akka-user] Config for adding the Remote-Address header in Akka Http

I noticed there is a setting (akka.http.server.remote-address-header) that can be turned to on that should automatically add the Remote-Address header to all incoming requests. I set this to on using RC3 but I do not see the header being added. I searched through the source and saw the

[akka-user] Re: RoundRobinRountingLogic: A slightly faster version?

Have you profiled this to quantify the performance improvement, and if so, did you run it under high contention situations to be sure the locks on the atomic don't start to be an issue under high contention? On Thursday, May 28, 2015 at 11:43:24 AM UTC-4, Guido Medina wrote: Hi, I have my

Re: [akka-user] Re: Akka CQRS / Cluster Sharding - Change management of Events and other questions

scenario, and the suggested event-sourcing approaches recommend not to perform side effects while recovering state. -Chris On Monday, April 13, 2015 at 2:35:05 PM UTC-4, Greg Young wrote: Yep weak/hybrid schema all the way. So long as adding a field doesn't break downstream consumers then you

[akka-user] Akka CQRS / Cluster Sharding - Change management of Events and other questions

! -Chris -- 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.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka User List

[akka-user] Re: Akka Cluster + EC2, life cycle of seed node

. Chris On Friday, November 7, 2014 3:11:21 PM UTC-8, jxtps wrote: There https://groups.google.com/forum/#!searchin/akka-user/ec2$20seed$20nodes/akka-user/lBcl3WgEM_0/mocdn8-jmXsJ are a https://groups.google.com/forum/#!searchin/akka-user/ec2$20seed$20nodes/akka-user/_1oc9aEfEJw

[akka-user] Akka starting one thread per actor

. This is a single node cluster where I manually have it join itself. Any idea what I could be doing to trigger this? Chris -- 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.com

Re: [akka-user] Akka starting one thread per actor

, but the thread is still there. I think I might be importing some stuff from the java side that's conflicting, like Timeout from one library and Await from another, or something similar that's causing something to get confused and not interrupt the thread correctly. Chris On Tuesday, October 7, 2014 1

Re: [akka-user] Akka starting one thread per actor

Ya I was blocking using Await.result. Chris On Tuesday, October 7, 2014 2:31:49 AM UTC-7, √ wrote: Wdym catch the TimeoutException? You were blocking on the future? On Tue, Oct 7, 2014 at 11:28 AM, ch...@ochsnet.com javascript: wrote: Really strange bug. So I had an ask when it should

[akka-user] Akka design patterns for high read/write environments (multiplayer games)

I really formalize it more, I want to get some feedback. Chris -- 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.com/group/akka-user --- You received this message because

[akka-user] Bottleneck with StreamTcp and long lived connection?

I've been playing with the Tcp module for a while now, trying to use it to build a Memcached client that performs as well as the spymemcached java client does. I got stuff working a while back with the plain Tcp extension but the code was tricky (back pressure handling) and always seemed to

[akka-user] Unbinding a StreamTcp server binding

I can't currently find a way to perform an Unbind with a StreamTcp server binding. What if for some reason I no longer want to be connected to that socket. The regular Tcp binding has a way to do this (by sending an Unbind to whoever responded to the original Bind request), but I don't see

Re: [akka-user] Cluster Sharding Supervision Strategy

) system.shutdown() Thread.sleep(2000) println(sRecovered ${RecoveryMetric.count.toString} times) } } On Wednesday, September 17, 2014 11:12:59 AM UTC-7, Chris Carter wrote: If it helps, here's a simple test case recreating the scenario as we're experiencing it. The environment we're

Re: [akka-user] Cluster Sharding Supervision Strategy

Thanks Patrik, I've created an issue here: https://github.com/akka/akka/issues/15943 I updated the example to include the RecoveryFailure option, I realized we're not handling that in our production code either. Thanks for the reminder! Chris On Thursday, September 18, 2014 1:11:09 AM UTC-7

Re: [akka-user] Cluster Sharding Supervision Strategy

was being logged 1000s of times in a few seconds). Does that make sense? Either way - it sounds like the approach we settled on for now (the supervisor + child) is the way to go, so we'll stick with that. Thanks a lot for the reply and advice! Chris On Wednesday, September 17, 2014 12:06:55 AM

Re: [akka-user] Cluster Sharding Supervision Strategy

[RecoverMe])) actor ! MyCommand(None) Thread.sleep(5000) system.shutdown() Thread.sleep(2000) println(sRecovered ${RecoveryMetric.count.toString} times) } } On Wednesday, September 17, 2014 10:18:11 AM UTC-7, Patrik Nordwall wrote: On Wed, Sep 17, 2014 at 5:59 PM, Chris

[akka-user] Cluster Sharding Supervision Strategy

the ActorSystem itself, do I have to create a specific guardian actor for particular Shard systems? Or do I just have to set the default supervisor strategy for the whole system and rely on the Shard actors picking that up? Thanks for any hints you guys can provide! Chris -- Read the docs: http

[akka-user] Re: How to split an inbound stream on a delimiter character using Akka Streams

to tighten up the internals of the code. I will use this code here as a guideline. Thanks. On Wednesday, September 3, 2014 8:15:33 AM UTC-4, Chris Baxter wrote: Posted this on Stackoverflow but haven't seen any activity on it so I figured I'd post it here as well. I've been playing around

[akka-user] How to split an inbound stream on a delimiter character using Akka Streams

Posted this on Stackoverflow but haven't seen any activity on it so I figured I'd post it here as well. I've been playing around with the experimental Akka Streams API a bit and I have a use case that I wanted to see how to implement. For my use case, I have a `StreamTcp` based `Flow` that is

[akka-user] Re: How to split an inbound stream on a delimiter character using Akka Streams

Thanks for the suggestions Viktor and Endre. I will try Viktor's chop solution as well as looking into the Endre's Transformer solution (and the decoding DSL) and then post back with my results. On Wednesday, September 3, 2014 8:15:33 AM UTC-4, Chris Baxter wrote: Posted

Re: [akka-user] How to split an inbound stream on a delimiter character using Akka Streams

a Transformer and use the `transform` method. On Wed, Sep 3, 2014 at 3:55 PM, Chris Baxter cba...@gmail.com javascript: wrote: Viktor, how would this work if the delimiter was not in the current ByteString, meaning that it's coming in a subsequent ByteString and I need to buffer this ByteString

[akka-user] Re: How to split an inbound stream on a delimiter character using Akka Streams

:15:33 AM UTC-4, Chris Baxter wrote: Posted this on Stackoverflow but haven't seen any activity on it so I figured I'd post it here as well. I've been playing around with the experimental Akka Streams API a bit and I have a use case that I wanted to see how to implement. For my use case, I

[akka-user] Typesafe console dependencies

I am trying to use the typesafe console with the atmos sbt plugin. I find building the system difficult because I get Akka version not supported by Typesafe Console. On a test project I was able to get past this by down grading my scala and akka versions. This won't work on my current project.

[akka-user] Re: how to tune akka remoting performance

. That coupled with a few thread dumps, and you should find the source of problem without too much effort. Chris -- 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.com/group/akka

Re: [akka-user] Dependency injection of ShardRegion actor

. ActorRef? Using an implicit conversion from entry name to ActorRef is an interesting alternative too, thanks. Chris On Fri, Jul 18, 2014 at 8:02 AM, Martynas Mickevičius martynas.mickevic...@typesafe.com wrote: Hi Chris, if the ShardRegion will get restarted by its guardian, ActorRefs

Re: [akka-user] Dependency injection of ShardRegion actor

Thanks Patrik. So is a general rule then if one knows enough about the implementation to know that a given type of actor won't ever be stopped, it's safe to use its ActorRef for the lifetime of the ActorSystem, otherwise one should use an ActorSelection instead? Chris On Fri, Jul 18, 2014

[akka-user] Dependency injection of ShardRegion actor

right in assuming that the performance overhead of 1) and 2) are comparable, and negligible in the grand scheme of things, compared to sending directly to the ActorRef? thx, Chris -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional

[akka-user] Contents link in HTML documentation pages

again. Do other folks here agree that the navigation is inconvenient as is and would be improved with this change? thx, Chris -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

[akka-user] Re: Akka Microservice platform

to use from ruby. Chris -- 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.com/group/akka-user --- You received this message because you are subscribed to the Google Groups

[akka-user] managing intelligent agents

this before and has found a better approach? I'm not unhappy with it, but that doesn't mean there isn't a better way. Chris -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

[akka-user] Re: managing intelligent agents

like your idea about a receive timeout, never thought of that approach might come in handy. Thanks for the input! Chris -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

[akka-user] Actor creation changes in Akka 2.3

, so I will go to dark places to solve this if I absolutely have to, I just don't want to do that:) Chris -- 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.com/group/akka

[akka-user] Re: Actor creation changes in Akka 2.3

On Monday, June 2, 2014 1:03:18 PM UTC-7, Chris Ochs wrote: So 2.3 introduced changes that wreck havoc with those of us using Akka from languages like Jruby. Namely being forced to pass java classes to props instead of being able to pass instances. stack overflow has a question about

[akka-user] Re: Pulling Pattern vs Durable Mailboxes

the same in Chrome, Firefox, and IE so not a browser issue. Would be great if you could correct that to make post fully readable again :-). Chris On Tuesday, May 6, 2014 8:38:19 AM UTC-7, Ryan Tanner wrote: I'm the author of the blog post from Conspire you referenced. In our case, losing

[akka-user] Re: Strange behavior with Akka Tcp

of the core IO stuff. I'm really waiting for reactive streams to come out and then I plan on building on top of that as it will be much cleaner and simpler. On Friday, April 11, 2014 2:32:37 PM UTC-4, Chris Baxter wrote: I'm using the latest release of Akka (2.3.2) and I've been playing around

Re: [akka-user] Best way to communicate with an Actor?

Curious how would you recommend accomplishing that in this example (getting messages to /project/someactor containing ActorRefs for actors /project/users/user-X, /project/users/user-Y, /project/users/user-Z)? Chris On Wednesday, April 16, 2014 12:15:15 PM UTC-7, √ wrote: Hi Chanan, I'd say

[akka-user] Using akka.persistence.Reset from Java

() constructor doesn't exist, and indeed when I decompiled the Reset.class file in the persistence jar file it didn't show a constructor. I'm using akka 2.3.2. Is there a different way to do this channel reset from Java? thx, Chris -- Read the docs: http://akka.io/docs/ Check the FAQ

Re: [akka-user] Wireshark tells me, that the data arrived 17 seconds before akka raises a Received event, why?

to reproduce this issue on over machines or a VM. On Sunday, April 13, 2014 9:04:30 PM UTC+2, rkuhn wrote: Wild guess: is your powershell counting GPS time while your capture uses UTC? The current offset is 16 seconds. 4 apr 2014 kl. 17:52 skrev Chris Vaas chri...@gmail.com javascript:: As you

[akka-user] Strange behavior with Akka Tcp

I'm using the latest release of Akka (2.3.2) and I've been playing around with the Tcp Api a bit, trying to get familiar with how it works. In doing so, I've been writing a little Memcached binary client. This usage of Tcp is a little different then the examples in the docs in that the

[akka-user] File I/O design

I am new to Akka and am converting an existing program to use it. The program reads a set of files, processes the data, and writes reports to 20 files. The data is read and processed sequentially. It seems like a good project to start with. I plan to offload the writing of the files to 20

Re: [akka-user] Custom SupervisorStrategy in Java?

, Chris On Tuesday, April 8, 2014 5:44:37 AM UTC-4, √ wrote: Hi Chris, already exists: http://doc.akka.io/japi/akka/2.3.1/akka/actor/OneForOneStrategy.html#OneForOneStrategy(int, scala.concurrent.duration.Duration, akka.japi.Function) On Mon, Apr 7, 2014 at 10:25 PM, Chris Curtin

Re: [akka-user] Custom SupervisorStrategy in Java?

Hi, Thanks for pointing me to DeathWatch. I missed how it could be used with the SupervisorStrategy, but get it now. The two together are doing what we want. Thanks, Chris On Tuesday, April 8, 2014 9:54:22 AM UTC-4, √ wrote: Why not use DeathWatch? On Tue, Apr 8, 2014 at 3:45 PM, Chris

[akka-user] Re: Akka TCP Server does not receive data after too many connections

Dear Björn, you were perfectly right. It seems that the problem was selfmade. Thank you very much for your time. Problem solved :-) On Thursday, April 3, 2014 9:59:39 AM UTC+2, Chris Vaas wrote: The following code is a basic TCP server and client, that should communicate. But the log

Re: [akka-user] Production monitoring tools?

Thanks Patrik, that looks like a great, simple template for monitoring mailbox size with statsd, etc. Chris On Thu, Mar 27, 2014 at 1:43 AM, Patrik Nordwall patrik.nordw...@gmail.comwrote: The LoggingMailbox https://gist.github.com/patriknw/5946678 has helped me debugging bottlenecks many

Re: [akka-user] Re: Production monitoring tools?

Thanks Edward, very helpful. We already use statsd and graphite for our other apps and are also big fans of it. Will take a look at your client, thanks for sharing. Chris On Wed, Mar 26, 2014 at 12:55 PM, Edward Steel edward.st...@gmail.comwrote: We're using a combination of things at work

Re: [akka-user] Re: Production monitoring tools?

monitoring mailboxes (contrary to the blog post and you guys working on queue counters instead)? If so, can you explain, or if not, what did you mean? thx, Chris On Wed, Mar 26, 2014 at 3:00 PM, Ivan Topolnjak ivant...@gmail.com wrote: Chris, 1) Generic JVM metrics There are many approaches

[akka-user] Re: Sbt multi-jvm test in subproject and parallel execution

Could be related to this issue which is not fixed yet as far as I know: https://github.com/sbt/sbt/issues/882 On Wednesday, March 12, 2014 8:27:25 PM UTC+1, Allan Brighton wrote: Hi all, I have a multi-jvm test in a subproject that runs fine if I am in the project, but gives Failed to bind

Re: [akka-user] dead letter error when sender dies immediately after sending the message

and callingpostStop) and then I stopped calling 'super.preRestart' and it started to work. Am I correct that the SupervisoryStrategy of the children have no bearing when Akka is doing the restart()? Thanks for your help, Chris On Friday, March 7, 2014 9:17:37 AM UTC-5, Björn Antonsson wrote: Hi Chris

Re: [akka-user] Remoting: Service discovery (non-cluster) and specifying hostname/port

discovery, you could trivially implement this using JSON over HTTP but ideally you want something more dynamic. But this is an orthogonal problem to akka Chris On Mon, Dec 23, 2013 at 12:49 AM, Ryan Tanner ryan.tan...@gmail.com wrote: We use Vagrant and Chef to deploy our Akka cluster on AWS