Re: [akka-user] Can quarantine happen without remote actor creation or watching?

Yeah, for example if irrecoverable loss of system messages happens. In general death watch on Actors using remoting can in failure scenarios (see above) lead to a Quarantine. Note that Quarantine is irrecoverable, unlike "Unreachable" which is used in the Cluster. Short answer: Use the Cluster

Re: [akka-user] Java-friendly "ask"

Happy hakking! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Lightbend On 24 February 2016 at 16:53:43, Tal Pressman (kir...@gmail.com) wrote: Hmm, not sure why I didn't find it myself. Sorry for the dumb question... Thanks for the quick reply, though! ^_^ -- >> Read the docs:

Re: [akka-user] Java-friendly "ask"

Hi Tal, thanks for pointing out it's not linked to in the docs around `ask`. We have one and it's available in `akka.pattern.PatternsCS`, so you can import statically from that object and it'll read nice (`ask(who, what): COmpletionStage`) :-) I'll add a note to the docs as well: 

Re: [akka-user] Intended use for akka.Done and akka.NotUsed

alized value.   Cheers, Rüdiger On Wednesday, February 24, 2016 at 11:43:33 AM UTC+1, Konrad Malawski wrote: Hey Rüdiger, yeah those can definitely be used in all kinds of APIs. The reason we have them mostly in Streams for now is because we could not break compatibility in akka-actor for e

Re: [akka-user] Intended use for akka.Done and akka.NotUsed

Hey Rüdiger, yeah those can definitely be used in all kinds of APIs. The reason we have them mostly in Streams for now is because we could not break compatibility in akka-actor for example. The types are intended to be simply more informative than plain `Unit`, so wherever that's needed feel

Re: [akka-user] Custom GraphStage with Java Future

Hi Gary, it's as simple as setting a dispatcher for a Flow. val flow = Flow[String].via(myBlockingStage).withAttributes(ActorAttributes.dispatcher(“my-configured-blocking-dispatcher”)) (setting a dispatcher also implies an asynchronous boundary). Of course try to avoid these blocking APIs,

Re: [akka-user] Why does this simple Akka Streams program never terminate?

Because Akka uses non-daemonic threads, so it'll keep the app running until you shut-down the ActorSystem. You can do so via: import system.dispatcher s.runForeach(println).onComplete { _ =>  system.terminate() } --  Cheers, Konrad 'ktoso’ Malawski Akka @ Lightbend On 23 February 2016 at

Re: [akka-user] Disable hostname verification

awski Akka @ Typesafe On 19 February 2016 at 17:15:23, Endre Varga (endre.va...@typesafe.com) wrote: Cannot the self-signed certs be added to the truststore though? That would be the "proper" workaround. -Endre On Fri, Feb 19, 2016 at 5:12 PM, Konrad Malawski <konrad.malaw...@typesafe

Re: [akka-user] Disable hostname verification

On Friday, February 19, 2016 at 4:55:56 PM UTC+1, Konrad Malawski wrote: Hi, Have you tried setting akka.ssl-config.hostnameVerifierClass to your custom "accept everything" classname?   --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 19 February 2016 at 16:45:55, Michi (michael...

Re: [akka-user] Akka-http request timeout exception

Thanks for reporting, likely it's harmless if happened after timeout but maybe we can make it note silent, please report as an issue, thanks! On Feb 18, 2016 20:57, "David Knapp" wrote: > After upgrading from 2.0.3 to 2.4.2, I'm getting this error when one of my >

Re: [akka-user] [ANNOUNCE] Akka 2.4.2 including Streams and HTTP Released!

--  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 18 February 2016 at 10:46:42, Endre Varga (endre.va...@typesafe.com) wrote: One question: will there be a release for Scala 2.10 (i.e., 'com.typesafe.akka:akka-actor_2.10:2.4.2')? No. The rule is and has always been that we release for

Re: [akka-user] Re: [ANNOUNCE] Akka 2.4.2 including Streams and HTTP Released!

I've migrated and everything compiles except the http route test. Tests like the one shown don't compile, "route" isn't found.   it should "respond with handled = false for partial path" in {     Get(saPath) ~> route ~> check {       handled shouldEqual false     }   } I don't see how to

[akka-user] [ANNOUNCE] Akka 2.4.2 including Streams and HTTP Released!

*Dear hakkers,* we—the Akka committers—are proud to announce the FINAL RELEASE of Akka 2.4.2. The main change in this release is that it includes Streams & HTTP. Some of these new modules are still marked experimental due to impending API changes that we could not yet finish, in particular

Re: [akka-user] Failing a stream when a downstream branch fails

Errors only flow downstream. So in order to take a downstream error and make it fail something "upstream"... you'll have to connect that downstream to the upstream so it becomes a downstream :-) I hope that made sense :-) In general though, you could make a fan-out operation from your

Re: [akka-user] Re: Akka dispatchers are not reused instead new dispatchers are created overtime

You may want to read my SO answer which explains what you're seeing somewhat (including pictures and how to configure dispatchers properly): stackoverflow.com/questions/34641861/akka-http-blocking-in-a-future-blocks-the-server/34645097#34645097 --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe

Re: [akka-user] Re: Akka streams file compression

port for compression!) On Tue, Feb 16, 2016 at 2:13 PM, Konrad Malawski <kt...@typesafe.com> wrote: Hi Richard, Not that I'm aware of.  You can ping the library maintainer to upgrade to 2.4.2 (we're releasing that today) though :) On Tue, Feb 16, 2016 at 1:45 AM, Richard Rodseth &l

Re: [akka-user] Akka dispatchers are not reused instead new dispatchers are created overtime

Hi there, Could you share your configuration first and also how you're observing the described problem? Do you have a reproducer for this mesbehaviour? --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 16 February 2016 at 16:33:21, Hareesh Jagannathan (harjag...@gmail.com) wrote: Akka

Re: [akka-user] Akka Stream Example

Hi there, the docs are:  https://github.com/akka/akka/blob/master/akka-docs/rst/scala/stream/stream-quickstart.rst from there you can find the includecode snippets pointing to:  https://github.com/akka/akka/blob/master/akka-docs/rst/scala/code/docs/stream/TwitterStreamQuickstartDocSpec.scala

Re: [akka-user] How to persist path dependent types with Protobuff?

Hi there, Protocol buffers don't really works on "any case class", you have to map values to protoc generated message classes, (middle collumn in the example), whihc are generated from an IDL shows on the left hand side column here: https://developers.google.com/protocol-buffers/ Read up on how

Re: [akka-user] Re: Akka streams file compression

Hi Richard, Not that I'm aware of. You can ping the library maintainer to upgrade to 2.4.2 (we're releasing that today) though :) On Tue, Feb 16, 2016 at 1:45 AM, Richard Rodseth wrote: > I just had the rather gratifying experience of adding Snappy compression > using

Re: [akka-user] Akka HTTP Java Directives examples

too much and if we have to rewrite a layer of the app then so be it. Is there a SNAPSHOT/nightly build version or the likes where I can try out the new DSL? Thanks again, Dan On 15 February 2016 at 15:49, Konrad Malawski <konrad.malaw...@typesafe.com> wrote: Hi Daniel, Before I dive int

Re: [akka-user] Akka HTTP Java Directives examples

Hi Daniel, Before I dive into your question I'd like to highlight that the Java directives are undergoing an intense rewrite just now (they're still experimental, so that's why we must do it now),  and will be way more elastic soon:  https://github.com/akka/akka/pull/19632/files?diff=unified So

Re: [akka-user] [Akka Http] Route parameters in low level API

Hi Matthieu, Akka HTTP's low level is what it is – low level :-) No, we don't provide any routing capabilities like this in the low level api. Why don't you want to use the high level routing DSL? It has nice support for those things built in. If it's not an option, you can parse the Uri and

Re: [akka-user] FileIO in 2.4.2-RC3

Hi RIchard, there's a PR fixing this and the larger issue which is JDK8 types exposure in that API. Will be merged any moment now: https://github.com/akka/akka/pull/19636 for 2.4.2. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 15 February 2016 at 05:47:23, Richard Rodseth

Re: [akka-user] Routing DSL self documentation?

Hi there, this has been a hot topic for quite some time. There exist attempts to implement it in the community, for example: https://github.com/Tecsisa/akka-http-swagger or https://github.com/devsprint/akka-http-swagger For an in depth discussion why it's hard to implement see this issue: 

Re: [akka-user] Auto Restart actor when cluster node fails

Sounds like you're asking about:  http://doc.akka.io/docs/akka/2.4.1/scala/cluster-sharding.html#Remembering_Entities Have you seen that feature? :) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 9 February 2016 at 16:01:06, Paul Cleary (pclear...@gmail.com) wrote: I am using Cluster

Re: [akka-user] StateData mutability in AbstractFSM

Technically it may be safe in that case, you're in an Actor after all. However I'd argue it's bad style as it mixes an API designed for immutable data passing (the data param of FSM), in a mutable way, which can/will lead to confusion when someone else reads your code. If you want to have (or

Re: [akka-user] StateData mutability in AbstractFSM

(jsp0...@gmail.com) wrote: Hi Konrad, Thanks for the guidance, much appreciated! Good points, will try to stick to immutable data params for FSM. Have a great weekend :) On Friday, January 29, 2016 at 3:40:23 PM UTC-8, Konrad Malawski wrote: Technically it may be safe in that case, you're

Re: [akka-user] [Akka-stream] How to log element pass into a Graph ?

Have you tried? s ~> Flow[Element].log("...") ~> thingy --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 20 January 2016 at 10:56:01, Richard Grossman (richie...@gmail.com) wrote: Hi When working with simple flows you can add between steps log directive. like Flow.log("start").map

Re: [akka-user] Akka HTTP File Not Found Exception

Oh wait you should check http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/http/directives/file-and-resource-directives/getFromFile.html I'm already in bed though ;) On Jan 16, 2016 00:01, "Konrad Malawski" <konrad.malaw...@typesafe.com> wrote: > This may

Re: [akka-user] Akka HTTP File Not Found Exception

This may be a bug, I'll look into it soon so thanks for reporting! Glad you liked the talk :-) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 15 January 2016 at 23:57:01, Gustavo Politano (gustavo.polit...@gmail.com) wrote: Hi! I was watching Konrad's workshop from Scala eXchange -

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

/invaliddependency I will compile this from my home machine to check that it is not some local configuration weirdness. But we have had this happen from two machines at work... On Tuesday, January 12, 2016 at 4:55:31 PM UTC+1, Konrad Malawski wrote: It should work properly. There was a PR

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

It should work properly. There was a PR refactoring that area, indeed:  https://github.com/akka/akka/pull/19066/files Are you sure you don't have mixed up akka http dependencies or something like that via messy dependencies? You mention you looked at dependencyTree so that would show up there

Re: [akka-user] Where is the akka-http source code online?

They're on a branch, documented here currently:  https://github.com/akka/akka/blob/master/CONTRIBUTING.md#branches-summary The branch is `release-2.3-dev`, it's exclusively for Akka HTTP and Streams development while they were heavily experimental.

Re: [akka-user] Recommended Seed Node Number

Konrad, thanks for the quick reply.  Our nodes are similar (receive same traffic on same hardware).  We have frontend and backend node roles (10 FE, 16 BE).  Does 4 nodes (2 from each role) sound reasonable?  Seed nodes are just "the nodes to which a new node talks to in order to join the

Re: [akka-user] akka-http: access to httpresponse

Hi there, You're the one creating the HttpResponse directly if you want to modify it, see: import akka.http.javadsl.model.*; return ctx.complete( HttpResponse.create() .withEntity(HttpEntities.create("example")) .addHeader(Location.create("http://akka.io;))); Happy hakking! -- 

[akka-user] Re: akka-http: access to httpresponse

I improved the docs slightly to show this style of completing as well: https://github.com/akka/akka/pull/19350 -- Konrad -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

Re: [akka-user] Re: ClassCastException when persisting events using akka-persistence

Do you have some collections involved in the pattern match perhaps? Show us your receiveCommand / receiveRecover. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 5 January 2016 at 15:55:18, matheusl...@sagaranatech.com (matheusl...@sagaranatech.com) wrote: Sorry, I've read fast your

Re: [akka-user] Akka cluster seed nodes sequence

Please read up on the Akka Cluster documentation: http://doc.akka.io/docs/akka/snapshot/java/cluster-usage.html Quote: The seed nodes can be started in any order and it is not necessary to have all seed nodes running, but the node configured as the first element in the  seed-nodes configuration

Re: [akka-user] Aggregate counts in multi-jvm testing

But now, there's one thing that I'm not too happy about: both distributed pubsub and distributed data seem to replicate all data onto all nodes instead of spreading out to the cluster.  That's not true – pubsub only sends data to such nodes, which subscribed to a given topic. If all people

Re: [akka-user] Aggregate counts in multi-jvm testing

API simplicity is one thing – runtime, failure and recovery semantics are another, that's there the dragon lies. My only point here is, that it's tricky to have 2 clusters being running in the same jvm, because there's much more failure scenarios you suddenly have to think about:  - what if Akka

Re: [akka-user] GraphDSL.create is not visible for IDE

.create() is a normal method on the companion - it should just work. Did you find out what the problem was? --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 25 December 2015 at 01:19:15, Anton Kulaga (antonkul...@gmail.com) wrote: Hi. I updated my project to akka-http-experimental 2.0.1

Re: [akka-user] Bounded Mailboxes and throttling

Hi Jochen, The bounded mailboxes are designed around the idea that in Akka delivery is at-most-once in any case (because network, and no re-delivery – unless you use AtLeastOnceDelivery or do it yourself). So yeah, they're protecting the receiver, nothing more - it's not a full-blown

Re: [akka-user] Aggregate counts in multi-jvm testing

lities like locking or queries. The data is also replicated on all nodes which can be too much redundancies (or is it configurable?). On Friday, December 25, 2015 at 8:13:18 AM UTC-6, Konrad Malawski wrote: After having consulted a number of customers who included or previously-had hazlecast clusters a

Re: [akka-user] Aggregate counts in multi-jvm testing

After having consulted a number of customers who included or previously-had hazlecast clusters along with  Akka apps I remain unconvienced what hazlecast added to the table (other than - "yet another cluster, with different and detached lifecycle to manage"). I'd avoid adding more separate

Re: [akka-user] Aggregate counts in multi-jvm testing

Without going much deeper – I certainly wouldn't add any of these to a project just to get a CRDT counter ;-) Also, we have those too:  http://doc.akka.io/docs/akka/snapshot/scala/distributed-data.html :-) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 25 December 2015 at 11:22:07,

Re: [akka-user] Aggregate counts in multi-jvm testing

You're in a distributed system – how would you do it there? "The Akka way" of doing it is messaging :-) Send a message to the "cluster actor", which each JVM has,  from the same sender, collect the replies, once you got all of them (and you know, because you know how many questions you've sent),

Re: [akka-user] Update http routes

Not built in but doable, see  https://github.com/movio/spray-dynamic-routing-example for inspiration. You should be able to translate it to Akka HTTP. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 24 December 2015 at 10:17:23, greg.kam...@bcgdv.com (greg.kam...@bcgdv.com) wrote: Hi,

Re: [akka-user] Re: akka-http how to set global timeout for http services

Sorry, I've misread your question - you mean a request-timeout. I'm not sure from the top of my head, will revisit this after christmas dinner. I quickly grepped and it may be missing still, could you open a ticket for this? On Thu, Dec 24, 2015 at 3:02 PM, Konrad Malawski < konrad.ma

Re: [akka-user] Re: akka-http how to set global timeout for http services

Grep the rederence.conf of Akka http core for 'idle-timeout'. We also have it documented AFAIR, but not at my laptop now. On Dec 24, 2015 15:00, "Richard Grossman" wrote: > Hello > > I see that nobody answer to this > Any news ? > > On Tuesday, November 10, 2015 at 8:04:37

Re: [akka-user] Akka PersistenceQuery java example

Hi Jan, please read about Akka Persistence. >From your code snippet it's not possible to say if the events are persisted under the persistenceId "persistentActor-4-java" or not. What's the def persistenceId in the Actor look like? What is not working in the example you pasted? -- Konrad On Wed,

Re: [akka-user] Migrating to akka stream 2.0.1, tests throw assertion error "`remaining` may not be called outside of `within`"

This sounds a bit weird... I don't think those changed that much in the move to 2.0. Could you make the problem example a gist (gist.github.com or complete snippet in email, ready to copy/paste) I could downlaod and quickly have a look? Thanks in advance! --  Cheers, Konrad 'ktoso’ Malawski

[akka-user] [ANNOUNCE] Akka Streams & HTTP 2.0.1 released!

Aclosed> milestones on github for your reference. Credits We would like to thank Mathias Bogaert for swiftly trying out the latest release and submitting a small improvement to HTTP’s domain model, thanks! commits added removed 8 228 82 Konrad Malawski 3 619 38 Rolan

Re: [akka-user] Fusing in akka-streams 2.0

FYI, Roland's docs update merged: https://github.com/akka/akka/pull/19268 I'll release 2.0.1 today as we found a bug in InputStreamPublisher. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 23 December 2015 at 09:14:58, Adam Warski (a...@warski.org) wrote: :-) But you are right, even

Re: [akka-user] Fusing in akka-streams 2.0

I'll leave the semantics questions to Roland or Endre to tackle (in general it should not change semantics), but a few quick ones: 2. how to insert async boundaries in linear pipelines? E.g.: Source(List(1, 2, 3))       .map(_ + 1)            .addAttributes(Attributes.asyncBoundary)      

[akka-user] ANNOUNCE: Akka Streams & Http 2.0 released!

Akka Streams since it has hit 1.0 a few months ago: commits added removed 8078222022 Konrad Malawski 7158031316 Johannes Rudolph 4252921142 Alexander Golubev 3279543082 Mathias 2739324035 Viktor Klang 26 106343554 Endre Sándor Varga

Re: [akka-user] Re: ANNOUNCE: Akka Streams & Http 2.0 released!

Correct, as has been forecasted for Akka itself in December 2014 – https://www.typesafe.com/blog/akka-roadmap-update-dec-2014 and is the case for Akka 2.4.x currently – we require JDK8 moving forward. The 2.0.x series of Akka Streams and HTTP is the last one available for pre-JDK8. We did both

Re: [akka-user] Re: Streaming http call gives EntityStreamSizeException (2.0-M2)

It's a feature. (yes, really) :-) Allow me to explain; Akka HTTP always opts on the safe side of things. For example, if you write an endpoint that can get POST data, and someone (an attacker) sends you data and it never ends sending... You do want to kill that connection as soon as you notice

Re: [akka-user] Re: Streaming http call gives EntityStreamSizeException (2.0-M2)

vrijdag 18 december 2015 14:17:47 UTC+1 schreef Konrad Malawski: It's a feature. (yes, really) :-) Allow me to explain; Akka HTTP always opts on the safe side of things. For example, if you write an endpoint that can get POST data, and someone (an attacker) sends you data and it never ends sending

Re: [akka-user] Re: Akka persistence query examples

On Thu, Dec 10, 2015 at 7:53 AM, Alan Johnson wrote: > I'm new to this space, but yes, it seems to me like the read store should > store lastProcessEventNr someplace, ideally updated in the same transaction > that updates the view. Welcome to the community then :-) Yup,

Re: [akka-user] [akka-http] performance improvements in 2.0

Hi Giovanni, "We're working on it". M2 has the parts needed to enable stream fusing. Currently we're working on enabeling it for the most complex pipelines – the Akka HTTP pipeline. 2.0 will be out before x-mas, it's a time based release. We're expecting those changes to be in it. We're not

Re: [akka-user] Can't build from source

We have not changed our build process so it's the same as a year ago, sure :-) It is documented here:  http://doc.akka.io/docs/akka/snapshot/dev/building-akka.html including the option to disable diagrams if you need to. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 10 December 2015 at

Re: [akka-user] Transaction on same object processed by same actor

into some issues. So wanted to know if non-persistent actors are supported. Thanks, Karthik On Saturday, November 28, 2015 at 3:47:22 AM UTC-8, Konrad Malawski wrote: You should read up on cluster sharding: http://doc.akka.io/docs/akka/current/scala/cluster-sharding.html Such "to the same

Re: [akka-user] Conditionally applying NotInfluenceTimeoutReceive

Hi Rob, The marker trait NotInfluenceReceiveTimeout strictly works "for the given message type". You can not plug in logic as to when it should or should not influence the receive timeout - it would be really tricky and weird to represent. Instead you should model your timers explicitly, using

Re: [akka-user] Disable relative URI parsing in Akka HTTP?

Did you see: # Enables/disables the addition of a `Raw-Request-URI` header holding the # original raw request URI as the client has sent it. akka.http.server.raw-request-uri-header = off Perhaps it would address your need? --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 1 December 2015

Re: [akka-user] Transaction on same object processed by same actor

You should read up on cluster sharding: http://doc.akka.io/docs/akka/current/scala/cluster-sharding.html Such "to the same Actor, given an identifier" is exactly what it is designed for. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 28 November 2015 at 11:59:52, Karthik Deivasigamani

Re: [akka-user] akka-http - how to log automatic Bad Request respoonses

Hi Jan, sure!  Here's how:  http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/http/routing-dsl/directives/debugging-directives/logRequest.html#logrequest I recommend implementing the "show", so it shows nicely (and not a raw bytestring as response body) while you're

Re: [akka-user] Re: Beginner's question: working with Futures inside Akka-HTTP 2 based API.

Awesome reply, thanks Tim! We also have this documented (though for spray-json instead of play-json) in our docs here: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/http/common/json-support.html Hope this helps! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On

Re: [akka-user] [akka-http] problem with multiple client requests using singleRequest

d somehow work > around the bug? > > On Fri, Nov 20, 2015 at 6:51 PM, Konrad Malawski > <konrad.malaw...@typesafe.com> wrote: > > Hi Rudiger, > > Yes it's a bug (two separate ones even, another thing you'll notice is > > actors leaking). > > And good news -

Re: [akka-user] [akka-http] problem with multiple client requests using singleRequest

Hi Rudiger, Yes it's a bug (two separate ones even, another thing you'll notice is actors leaking). And good news - we tracked it down and fixed it today! Will be released in M2 which will be released early next week. Thanks for reporting! On Nov 20, 2015 18:47, "rklaehn"

Re: [akka-user] [akka-http] problem with multiple client requests using singleRequest

Right; "this isn't rocket science" (-; All feedback is very welcome though Rudiger, please let us know if anything is non obvious or undocumented! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 20 November 2015 at 19:08:44, Konrad Malawski (konrad.malaw...@typesafe.c

Re: [akka-user] Play application with http / streams at 2.0-M1 fails to "run".

Play is not compatible with Akka Streams "2.0-M##" yet - it's a development milestone, not a release you can expect all libs to be ready for already. Please wait until Akka Streams "2.0" is released at which point Play will be updated to work with it. --  Cheers, Konrad 'ktoso’ Malawski Akka @ 

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

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 the cipher you're after:

Re: [akka-user] Re: I get strange error with 2.0-M1

Hi all, thanks for trying out the early Milestone and reporting the problem! We believe there is a bug in how the idle timeout was added, not sure if that specific problem is a manifestation of it, but we'll add more tests and fixes for idle timeouts in M2 (coming out soon), please keep an eye

Re: [akka-user] [akka-http] An issue with spay-son and collections

Usually one would do something like this: trait MyModelJsonProtocol extends DefaultJsonProtocol {   implicit val feedFormat = jsonFormat2(Feed) } object MyModelJsonProtocol extends MyModelJsonProtocol And use it like so: trait MyHelloWorldRoute extends MyModelJsonProtocol = {   val route =

Re: [akka-user] AKKA Http directive support for patch

Hi David, It's there already though :-) Docs:  http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/http/routing-dsl/directives/method-directives/patch.html /** * Rejects all non-PATCH requests. */ def patch: Directive0 = _patch --  Cheers, Konrad 'ktoso’ Malawski Akka @ 

[akka-user] Re: [scala-user] Re: Akka Stream and Http 2.0-M1 Released!

Hi Gary, (I think I replied to this already, but maybe you're only on scala-user and not akka-user? Sorry for duplicated email everyone else). yes, you should read the AsyncStage => GraphStage migration:

Re: [akka-user] AKKA Http directive support for patch

l.1...@gmail.com> wrote: > Sorry thank you, I should have looked better. I am just getting started > and when looking for patch I might have been looking at some older > documentation. > > Thanks > > On Tuesday, November 10, 2015 at 12:22:12 PM UTC-5, Konrad Malawski wro

Re: [akka-user] DeleteMessages in Akka Persistence

Yes it should. It's "delete messages to sequence nr 12". We have tests for it in the TCK, but it's up to the Journal implementations to corrently implement this. Which journal impl are you talking about? By the way, these things are very simple to check for yourself - just write a test which

Re: [akka-user] Re: Akka Stream and Http 2.0-M1 Released!

you should be able to figure out how to translate your Flexi things. There will be an M2 soon, then we'll explain in detail how to migrate from Flexi things. Hope this helps! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 7 November 2015 at 01:23:17, Konrad Malawski (konrad.ma

Re: [akka-user] [Akka Stream 2.0-M1] Quick blog post

Nice post, thanks for sharing! :-) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 7 November 2015 at 12:41:50, Gabriel Volpe (volpegabr...@gmail.com) wrote: The previous project was updated and the changes were pretty straight forward.

[akka-user] Re: Akka Stream and Http 2.0-M1 Released!

> > On Friday, November 6, 2015 at 4:19:49 PM UTC+3, Martynas Mickevičius > wrote: >> >> ... This is also the feature that will increase performance for various >> use cases, including HTTP. >> > > Is it just the first step, or significant part of the way, or almost the > whole way to make

Re: [akka-user] Re: Akka Stream and Http 2.0-M1 Released!

we had the help of 30 committers. 6354691117 Johannes Rudolph 46 5747 1609 Konrad Malawski 233331 688 Alexander Golubev 1775032397 Endre Sándor Varga 1527562955 Viktor Klang 12 499 345 2beaucoup 104160 689 Mathias 10 742 143 Martynas

Re: [akka-user] ReceiveTimeout and akka.test.timefactor

Hi Jan! Thanks for asking, This is expected behaviour though, not a bug. The akka.test.timefactor affects only the testing utilities, like expectMsg and it's friends. If you want to you can apply dilation manually, based on env variables to your timeouts (in prod code). Thanks and happy

Re: [akka-user] ReceiveTimeout and akka.test.timefactor

:31:09, Jan-Pieter van den Heuvel (jpie...@gmail.com) wrote: Then it must have been magic and not this configuration parameter that made the tests pass :) Thanks for your clear and fast reply! Op woensdag 4 november 2015 16:27:32 UTC+1 schreef Konrad Malawski: As I mentioned, akka.test.timefactor

Re: [akka-user] ReceiveTimeout and akka.test.timefactor

hat. Did I misunderstand? Kind regards, Jan-Pieter Op woensdag 4 november 2015 16:09:05 UTC+1 schreef Konrad Malawski: Hi Jan! Thanks for asking, This is expected behaviour though, not a bug. The akka.test.timefactor affects only the testing utilities, like expectMsg and it's friends. If you want

Re: [akka-user] count of all messages sent

Thats more of a task for monitoring tools, i.e. our reactive monitoring than manually building the same :) https://www.typesafe.com/blog/introducing-reactive-monitoring-v1-0-beta-reactive-platform On Oct 29, 2015 23:03, "akkauser" wrote: > is there any way to override

Re: [akka-user] Akka Actors unstashAll() with Predicate in Java

That's private API, please do not use it (it is marked as "INTERNAL API"). If you find yourself needing such filtering things, you should maintain a stash yourself (keep a list of items in the actor). --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 29 October 2015 at 14:10:41, Gohar

Re: [akka-user] akka http - could not find implicit value for parameter um: akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller

Hi there, what you've provided using DefaultJsonProtocol._ is Format objects (from spray json) to and from Boolean/Integer etc. Then you've provided a Format for your case class – so far so good. The problem here is that Akka Http does not know anything about Spray Json, as we want to allow

Re: [akka-user] Persistence of dynamic hierarchy of actors with short/medium length of life

Sounds great, thanks! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 22 October 2015 at 13:12:17, Robert Budźko (robert.krzysztof.bud...@gmail.com) wrote: Sure. I'm preparing workshops for my colleagues soon, so I'll merge part about intents into it and check if my examples are clear

Re: [akka-user] Persistence of dynamic hierarchy of actors with short/medium length of life

Yup, intent based approach makes it tick. I've already applied it successfully to the project.  Btw, I guess this is something other developers may bump into as well, would you be up to documenting this pattern? Either as part of the documentation or as a blog maybe? I fear intent hell now

Re: [akka-user] Spray 1.3.3 and Aka 2.4

2.4 and 2.3 are binary compatible, so you can just give it a try with 2.4.0 :) Happy hakking! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 21 October 2015 at 23:19:20, Richard Rodseth (rrods...@gmail.com) wrote: Is this possible? I've learned that migration from Spray to Akka HTTP

Re: [akka-user] How to scale up or out persistent actor for better throughput

Maatary – please do not cross post right away to multiple spots, it makes it really hard to track what's been answered and what not. If after a longer time you don't get a reply somewhere it's ok to cross post, for more exposure, however then please do link back to the answer you get somewhere

Re: [akka-user] Why is aroundReceive protected[akka]?

I'm not sure how many people actually use it - we have not seen too many questions about it. Which either means it 'just works' or no-one is using it :-) If you'd like to give it a spin and provide feedback that'd be awesome! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 21 October

Re: [akka-user] Re: Proposed major simplification of the Akka Streams FlowGraph APIs

My main beef with the scaladsl for FlowGraph.Builder is that it both requires the builder to be implicit (as in { implicit builder => }) but also requires import FlowGraph.Implicits._, both of which are hard to discover if all you do is to work with the code (and not reading docs). The

Re: [akka-user] Why is aroundReceive protected[akka]?

Hi Jan! Yes, it's definitely one of those  "Do not do this because you will most likely shoot yourself in the foot"? methods, and we believe it's much safer to keep it internal than to make it public, thus encouraging devs to use it (and end up in around-what-hell). We have used it very heavily

Re: [akka-user] Re: Behavior of Akka when you sleep in an actor

On Thu, Oct 15, 2015 at 4:44 AM, Fahimeh Rahemi wrote: > Please let me see if I understand your answer correctly, do you mean that > if I use thread.sleep(5000) inside an actor, the actor does not leave it's > thread at all? and the thread is idle and jobless for 5

Re: [akka-user] State of ZeroMQ support (Oct, 2015)

between processes. On Wed, Oct 14, 2015 at 9:54 AM, Konrad Malawski <kt...@typesafe.com> wrote: > ZeroMQ support has been deprecated and phased out a while ago. > More info about it's deprecation is mentioned in the RoadMap update in > 2014: > https://www.typesafe.com/blog/akka-r

Re: [akka-user] State of ZeroMQ support (Oct, 2015)

ZeroMQ support has been deprecated and phased out a while ago. More info about it's deprecation is mentioned in the RoadMap update in 2014: https://www.typesafe.com/blog/akka-roadmap-update-2014 While doing the deprecation we practically didn't see any feedback (we went around asking for it) that

Re: [akka-user] [akka-cluster] Large cluster or many clusters?

Hi Juan, In general it's best to think of a Cluster as something coherent - of if you want adding Roles to separate things a bit between nodes, but the cluster still serves one purpose – for example "a service" is backed by a cluster, which is multiple nodes but "one service" :) On Sat, Oct 3,

<    1   2   3   4   5   6   7   8   9   10   >