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
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:
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:
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
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
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,
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
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
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...
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
>
--
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
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
*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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
(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
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
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
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 -
/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
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
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.
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
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!
--
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
>>
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
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
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
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
.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
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
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
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
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,
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),
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,
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
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
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,
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
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
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
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 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
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
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
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
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,
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
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
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
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
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
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
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
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
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 -
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"
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
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 @
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:
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
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 =
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 @
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:
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
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
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
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.
>
> 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
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
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
: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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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,
401 - 500 of 903 matches
Mail list logo