The analogy of the JMM for Akka is also very interesting, it is an
important aspect of Akka to be aware
of http://doc.akka.io/docs/akka/2.4.0/general/jmm.html
On Monday, November 9, 2015 at 9:02:08 PM UTC, Stuart Reynolds wrote:
>
> In a highly concurrent system, it seems to me that the major be
I think you are looking at it from a very simplistic perspective without
taking into account many details that happen behind the scene, people tend
to use concurrent execution wrong where at the end of the day you still
have a finite set of processors -and small amount- so concurrent IMHO or at
Hi Kostas,
I have few micro-services and some supervisor actors which inherited from
an AbstractSupervisor template which uses local caches per microservices
with an optimistic approach, example with requirements:
1) There is a uniform pattern where each micro-service is an independent
categor
I have some code that will take some time to execute. This code runs in a
few steps with each step "blocking" for some time to store data into files.
I am thinking in creating a new actor which can receive 1 message for each
step. Will the block part affect only that actor or will other actors b
In a highly concurrent system, it seems to me that the major benefit of
using Akka is not in allowing concurrent computation (Futures work more
simply), but in ensuring correct execution of things that should not happen
concurrently (e.g. serializing access to state).
(from reading this: Don't u
I noticed one subtle thing in my cassandra entity persistence.
In my Subscriber class.
If I use the "ActorRef myEntity =
ClusterSharding.get(getContext().system()).shardRegion("MyEntity");" then I
see the persistence_id='counter-worker-MyEntity123'.
Where as, if I use the previously mentioned
*Source code github link:*
https://github.com/sdab75/akka-cluster-sharding-example/tree/master
I am struggling to get the persistent actor and akka cluster sharding
“supervisor” combination work.
The cluster sharding ‘without’ akka supervisor works fine i.e. in my
Subscriber if I get the
I'm looking at Akka as a possible framework for an application that's
distributed, stateful, and message-oriented, but have an odd roadblock -- I
can't use a straight TCP connection to communicate with the remote nodes. I
have to use a hybrid approach, where messages to and from the central
sys
Hi,
Just wondering if there is a way to specify a serializer for a specific
class (not specific message)?
For instance in my case i have a tree and instead of passing an actual node
of the tree i'd rather pass just the path of that node. This would save a
lot of additional serialization headac
Hi
I've define a flow like this:
def makeAST = Flow[String].log("Parse Json") map { json =>
Try {
val jsonMessage = parse(json)
val jsonNode = asJsonNode(jsonMessage)
val report = validator.validate(jsonSchema, jsonNode)
if (!report.isSuccess) throw new Exception("Vali
Hi,
I have a ClusterSharding whose remembered entries are PersistentActors,
using the cassandra journal.
The problem is if one of the node fails over (or if the cluster is fully
restarted), then all those entries try to recover at the exact same
time, overloading the persistence backend which so
My Bad, it turns out i didn't close the NingWs on play framework in case of
failure.
On Monday, November 9, 2015 at 12:31:45 PM UTC+7, Hengky Sucanda wrote:
>
> Hi all,
>
> Recently my system has been hit with a "too many open files" error.
> Attached is the result of running netstat -apn .
>
>
Happy hAkking!
On Mon, Nov 9, 2015 at 9:14 AM, Francesco Di Muccio <
francesco.dimuc...@gmail.com> wrote:
> Nice, I didn't think about it. The failure can be implemented using an
> Either, anyway I got the point, thank you very much.
>
> Il giorno domenica 8 novembre 2015 20:53:35 UTC+1, √ ha scr
Happy hAkking!
On 9 Nov 2015 03:57, "Akira Hayakawa" wrote:
> With some fixes on the client side explicitly adding Content-Type now
> works. Thanks Viktor.
>
> On Sun, Nov 8, 2015 at 9:28 PM, Viktor Klang
> wrote:
>
>>
>> http://stackoverflow.com/questions/5661596/do-i-need-a-content-type-for-ht
Nice, I didn't think about it. The failure can be implemented using an
Either, anyway I got the point, thank you very much.
Il giorno domenica 8 novembre 2015 20:53:35 UTC+1, √ ha scritto:
>
> Hi Francesco,
>
> You could emulate what you want using this:
>
> scala> val (q, f) = Source.queue[Optio
15 matches
Mail list logo
