Re: [akka-user][deprecated] Remoting With Artery

ttp://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" group. &g

Re: [akka-user][deprecated] How to recover Message if akka actor goes down for some reason?

Trying to collect dropped/lost messages via dead letters will not work reliably. For example it can be lost when sending from one node to another if there is a network problem at the same time. The only way to know that it arrived is to send acknowledgment message back, and if no acknowledgement

Re: [akka-user][deprecated] Re: Akka SSLSession leak when running Akka with native TLS

ibe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.

Re: [akka-user][deprecated] Re: Akka SSLSession leak when running Akka with native TLS

gt;>>>> 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" group. > To unsubscribe from this group and stop receiving emails from it, send an > email t

Re: [akka-user][deprecated] AKKA Stream mapAsync doesn't return elements by order

That sounds incredibly strange. Please create an issue with a reproducer that we can run. /Patrik ons 31 okt. 2018 kl. 23:04 skrev : > have a flow with mapAsync stage. This stage should emits its elements in > the same order they were pushed. I verified (using log printing) that > events are

Re: [akka-user][deprecated] Stashing messages in persistent typed actor 2.5.17

; + buffer.toString) > } > case a @ Accumulate(_) => > println("initial antes de stash " + buffer.toString) > buffer.stash(a) > println(&qu

Re: [akka-user][deprecated] Artery TCP ready for production?

The official status is as that note in documentation says. We want to harden it and input from you like this is very important. Please share dumps, logs, failure scenarios, whatever that is not working as expected. Create issues or continue questions/discussions at discuss.akka.io Thanks, /Patrik

Re: [akka-user][deprecated] I get a NoSuchMethodError when trying to run the project from the Akka docs - Getting Started Tutorial (Scala): First Chapter

s.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...

[akka-user][deprecated] Re: [akka-user] import context.dispatcher nullpointerexception

eiko >> >> -- >> >> Heiko Seeberger >> Home: heikoseeberger.de >> Twitter: @hseeberger >> Public key: keybase.io/hseeberger >> >> >> >> >> Am 07.03.2018 um 19:23 schrieb Patrik Nordwall <patrik@gmail.com>: >> >>

Re: [akka-user][deprecated] Artery Errors

18/03/13/discuss.akka.io- > announced > **** > * > >>>>>>>>>> > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>&

Re: [akka-user][deprecated] Does it fit to CRDT ?

I’m pretty sure that is just a standard terms of service document, and it’s absolutely not the reason for changing forum. /Patrik sön 8 apr. 2018 kl. 15:46 skrev Peter Corlett <ab...@cabal.org.uk>: > On Fri, Apr 06, 2018 at 05:17:17PM +0100, Alan Burlison wrote: > > On 06/04/1

Re: [akka-user][deprecated] What is the reason for that : "resolve of path sequence [/system/ddataReplicator/$PYi#-1343927577] failed"

gt;>>>> > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/ > current/additional/faq.html > >>>>>>>>>> Search the archives: https://group

Re: [akka-user][deprecated] Error message: New incarnation of existing member is trying to join. Existing will be removed from the cluster and then new member will be allowed to join.

Other log messages prefixed with “Cluster Node” would probably tell what’s going on. I’d suggest that you move the question to the new forum at http://discuss.akka.io /Patrik mån 2 apr. 2018 kl. 08:05 skrev Grace : > Hi all, > > I was running a cluster of four nodes,

Re: [akka-user][deprecated] Re: [akka-user] how to avoid or catch an akka.remote.transport.Transport$InvalidAssociationException

It should probably be changed to Warning level. PR fixing this would be welcome. /Patrik tis 27 mars 2018 kl. 16:31 skrev Zachary Marois : > If these are harmless, would ignoring any ERRORs from the > akka.remote.EndpointWriter class be safe? I definitely worry about hiding

Re: [akka-user][deprecated] Reasons that cause "leader change" in akka cluster

When another node with lower address is added. When there is a network partition (unreachable). Most often applications are more interested in using Cluster Singleton, and that is not the same as leader. If you have more questions I suggest that you post at the new http://discuss.akka.io/

Re: [akka-user][deprecated] Re: [akka-user] Announcing discuss.akka.io!

Hi Eric, You can setup email notifications as described in https://discuss.lightbend.com/t/how-to-use-the-discuss-forum-as-a-mailing-list/61 /Patrik fre 16 mars 2018 kl. 22:01 skrev Eric Swenson : > Konrad, > > Will new topics continue to be pushed to the mailing list as they

Re: [akka-user] Akka configuration setup for scale [bulk heading has been isolated to actors making http calls]

Can’t you use an async http client instead to avoid the blocking altogether? E.g. Play WS or Akka HTTP. /Patrik lör 10 mars 2018 kl. 22:11 skrev Amit Chavan : > Hello, > > I am redesigning a system that takes in messages on zmq and has to make > certain decisions and return

Re: [akka-user] Question on the WeaklyUp state

nd stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > --

Re: [akka-user] Akka Typed BehaviorTestKit with TimerScheduler

gle.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group,

Re: [akka-user] import context.dispatcher nullpointerexception

t; On Wednesday, March 7, 2018 at 6:09:24 AM UTC-8, Patrik Nordwall wrote: >> >> It's because when the actor is stopped some of the fields are cleared >> (yeah, even though they are vals) to "help" the GC in case something (e.g. >> an local ActorRef) is s

Re: [akka-user] import context.dispatcher nullpointerexception

; >> -- >> Cheers, >> √ >> > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/ > current/additional/faq.html > >>>>>>>>

Re: [akka-user] Akka cluster - issues with nodes getting stuck to Unreachable permanently

Sounds interesting/strange. For investigation it would be good with debug logging and verbose-heartbeat-logging. I think it is config akka.cluster.debug.verbose-heartbeat-logging=on, but check reference.conf /Patrik fre 2 mars 2018 kl. 15:47 skrev Manuel Bernhardt :

Re: [akka-user] Configuration Compatibility Check ignored when using Cluster(system).join(address)

akes the join process so different that nodes' configurations do > not need to be checked for compatibility? > > Thanks, Fred > > On Sat, Feb 24, 2018 at 8:27 PM, Patrik Nordwall > <patrik.nordw...@gmail.com> wrote: > > It’s only part of the joinSeedNodes process. Perhap

Re: [akka-user] Configuration Compatibility Check ignored when using Cluster(system).join(address)

It’s only part of the joinSeedNodes process. Perhaps that is missing in docs, and contribution fixing that is welcome. /Patrik lör 24 feb. 2018 kl. 18:13 skrev Frederic : > Hello all, > > I've just done a few tests with the new Configuration Compatibility Check > and

[akka-user] ANNOUNCE: Akka 2.5.10 released

table - deferred renamed to setup - ctx.spawnAdapter replaced by ctx.messageAdapter and ctx.ask Credits For this release we had the help of 36 committers – thank you all very much! commits added removed 38 9046 3376 Patrik Nordwall 32 8484 2425 Johan Andrén

Re: [akka-user] allow-java-serialization = off breaks remoting

On Thu, Feb 22, 2018 at 12:34 AM, Alan Burlison <alan.burli...@gmail.com> wrote: > On 21/02/18 19:14, Patrik Nordwall wrote: > > Search for serialization-bindings in reference.conf, which you find here: >> https://doc.akka.io/docs/akka/current/general/configura

Re: [akka-user] allow-java-serialization = off breaks remoting

urrent/additional/faq.html >>>>>>>>>>> Search the archives: https://groups.google.com/grou >>>>>>>>>>> p/akka-user >>>>>>>>>>> >>>>>>>>>> --- You received this message bec

Re: [akka-user] Getting a timeout error when testing a stream with mapAsync stage

btw, probably easier to use .runWith(TestSink.probe) in that example, or .runWith(Sink.seq).futureValue On Mon, Feb 19, 2018 at 12:12 PM, Patrik Nordwall <patrik.nordw...@gmail.com > wrote: > Doc improvement is welcome. If you add request(1) before the > expectComplete it’s n

Re: [akka-user] Getting a timeout error when testing a stream with mapAsync stage

nd any such change might break the > tests unexpectedly ? > > Jakub > > On Friday, February 16, 2018 at 9:55:45 PM UTC+1, Patrik Nordwall wrote: > >> It is allowed to ”delay” delivery of the complete signal when there is no >> demand. This behavior is undefined, i.e.

Re: [akka-user] Question on Akka router

The drawback of first sending everything to one single node would be “single point of bottleneck” and an extra network hop for many messages. Even though all frontend nodes might not have exactly the same load information at the same time that should be fine anyway. Load based routing is always

Re: [akka-user] Getting a timeout error when testing a stream with mapAsync stage

It is allowed to ”delay” delivery of the complete signal when there is no demand. This behavior is undefined, i.e. some stages deliver it immediately, some only when demand is requested. This is as expected and in such test you have to request enough to be sure to get the completed signal.

Re: [akka-user] Re: Swakka - a new extension to akka-http for Swagger/OpenApi

Thanks for the update Jeremey. Is the availability of this already mentioned in akka-http documentation? Otherwise I think it would be worth adding that somewhere. Please open an issue and we can work out the details. regards, Patrik ons 31 jan. 2018 kl. 20:32 skrev Philippe Derome

Re: [akka-user] Delay a gracefully shutdown when application shutdown hook has been detected

I think you can do that with Akka’s Coordinated Shutdown https://doc.akka.io/docs/akka/current/actors.html#coordinated-shutdown Register your task to one of the phases, instead of using jvm shutdown hook. Coordinated Shutdown will be triggered by jvm exit. /Patrik tis 13 feb. 2018 kl. 12:52

Re: [akka-user] Akka Persistence and avoiding var in favor of context.become

oglegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/>

Re: [akka-user] Question about multi data center behavior when a data center is empty

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 Use

Re: [akka-user] Akka typed - first impressions

n still use the "external ask" API, but it's > something to think about. > > > (As an aside, the PR also drew my attention to the fact that I was leaking > adapters, so that's something...) > > > Tal > > > > On Sunday, January 28, 2018 at 5:49:53 PM UTC+2, Patrik No

Re: [akka-user] Re: ANNOUNCE: Akka Multi-DC Persistence

solution to be prohibitively high? I'm asking because I was > considering implementing a similar thing (causal reliable broadcast over > Cassandra) with dynamic topology to handle the intra-DC netsplit scenario, > so I'd be glad to hear your thoughts. > > Thanks > Igor > >

Re: [akka-user] Akka typed - first impressions

Hi Tal, Thanks a lot for taking it for a spin and sharing feedback. Comments inline... sön 28 jan. 2018 kl. 14:10 skrev Tal Pressman : > I finally had the chance to use Akka Typed, and wanted to share my > experience. So basically, I took a small demo project that was based on

Re: [akka-user] akka persistence onPersistRejected vs onPersistFailure

The signature is def asyncWriteMessages(messages: immutable.Seq[AtomicWrite]): Future[immutable.Seq[Try[Unit]]] If the future is completed with exception it is the failure case, otherwise it’s possible to reject individual events as documented: * The journal can also signal that it rejects

Re: [akka-user] akka persistence onPersistRejected vs onPersistFailure

Hi Andrey, The purpose of ”rejected” is when it’s known that the event was not stored. Typically something that happens before the data store is called, such as serialization error. ”failed” is more uncertain. It might have been stored, it might not. E.g. A timeout of a db call. For rejected the

[akka-user] ANNOUNCE: Akka Multi-DC Persistence

overview of the feature, and more details can be found in the documentation <https://developer.lightbend.com/docs/akka-commercial-addons/current/persistence-dc/> . -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patrikn

Re: [akka-user] Re: Akka Streams 2.5 sudden throughput drop

Difficult to say what it can be without knowing what your code looks like. I suggest that you try to minimize it and share a reproducer or example. /Patrik mån 15 jan. 2018 kl. 15:05 skrev Dmitry Golubets : > One thing I want to add, is that sometimes there is actually one >

Re: [akka-user] Akka cluster sharding

A PersistentActor with a given persistenceId can only be active at one place (single writer principle). Cluster Sharding will help you with that. /Patrik fre 12 jan. 2018 kl. 09:08 skrev Martynas Mickevičius < martynas.mickevic...@lightbend.com>: > Hi, > > are your Cassandra nodes in one

Re: [akka-user] Disable Durable Storage for DData

ating on 2.5.8 I see a new folder called ddata. >>>> >>>> Thanks >>>> >>>> вторник, 9 января 2018 г., 22:52:36 UTC+3 пользователь Patrik Nordwall >>>> написал: >>>>> >>>>> Could you give some more context. It's not acti

Re: [akka-user] Disable Durable Storage for DData

Are you using Cluster Sharding with rememberEntities? tis 9 jan. 2018 kl. 21:52 skrev haghard <haghar...@gmail.com>: > Hello Patrik, after updating on 2.5.8 I see a new folder called ddata. > > Thanks > > вторник, 9 января 2018 г., 22:52:36 UTC+3 пользователь Patr

Re: [akka-user] Disable Durable Storage for DData

ost to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on th

Re: [akka-user] Akka 2.5.8 (Java Edition) Error initializing: java.lang.IllegalStateException: not yet initialized

rchives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.c

Re: [akka-user] Some questions about ConsistentHashingPool and PinnedDispatcher

You can get better throughput by using as many worker actors as cpu cores, if it is cpu bound. ConsistentHashingPool is one way. I don’t think you should involve pinned dispatcher. /Patrik fre 29 dec. 2017 kl. 08:49 skrev Leon Ma : > Hi, > > I have some general questions

Re: [akka-user] Akka typed ask and Scheduler

Hi Tal, I think it would be possible to grab the scheduler from internal impl, also for Typed. Please create an issue. /Patrik sön 31 dec. 2017 kl. 13:01 skrev Tal Pressman : > Hi, > > In "regular" untyped Akka, using `ask` only requires an implicit `Timeout` > whereas the

Re: [akka-user] ActorSystem and system.dispatcher, can those be used globally?

It’s fine (and best) to use one single ActorSystem. For the blocking you have to use a dedicated dispatcher as described in https://doc.akka.io/docs/akka/current/dispatchers.html#blocking-needs-careful-management An ActorSystem can have several dispatchers. /Patrik ons 13 dec. 2017 kl. 17:14

Re: [akka-user] Scalability of Akka Distributed Data

Hi Steffen, As documented Distribute Data has limitations with regards to data size. Crucial is to split it up to many top level entries. I’d suggest you try with 1000-1 top level entries. Even with delta-CRDTs it must sometimes transfer the full state, meaning that the message size for that

Re: [akka-user] Coordinated Shutdown

nsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <h

Re: [akka-user] Re: How to measure performance of Actor Message from one actor reaching to another actor

wnqvhQ7WkOGSBhvynPo9J9y_q4ed9FwCLcBGAs/s1600/Untitled%2BDiagram%2B%25282%2529.jpg> > > > > > > > > > > > On Saturday, December 16, 2017 at 1:09:42 PM UTC+5:30, √ wrote: >> >> Also, is serialization/deserialization included? At what point doe

Re: [akka-user] ClusterClient and graceful shutdown of ClusterReceptionist

; original message or rather having the cluster client setup a death watch on > the receptionist? > > Fred > > Le 16 déc. 2017 16:38, "Patrik Nordwall" <patrik.nordw...@gmail.com> a > écrit : > > Sounds like an excellent suggestion and contribution is we

Re: [akka-user] ClusterClient and graceful shutdown of ClusterReceptionist

Sounds like an excellent suggestion and contribution is welcome. Thanks, Patrik lör 16 dec. 2017 kl. 09:15 skrev Frederic : > Hi all, > > The ClusterClient is designed to connect to a single ClusterReceptionist. > When a cluster node running a receptionist gracefully

Re: [akka-user] Re: How to measure performance of Actor Message from one actor reaching to another actor

What are you interested in? Throughput (msg/s) or latency (us)? Remote or local? What will the results of the benchmarks be used for? /Patrik fre 15 dec. 2017 kl. 12:23 skrev Akka Team : > I think the floodPipe benchmark may do what you want, commented out but > you

Re: [akka-user] Help with dependencies using akka http 10.0.11 and akka stream 2.5.8

tis 12 dec. 2017 kl. 20:13 skrev Papelucho Nomas : > Arnout, > > > Short version: it was akka-streams-kafka 0.16. > > > Long version: I had to update "akka-stream-kafka" from "0.16" -> "0.18". > To keep things straight updated "kafka-clients" to "0.11.0.1" and >

Re: [akka-user] Akka Cluster: Auto shutdown if node fails to join(memberUp) the cluster

;>>>>> 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" group. > To unsubscribe from this group and stop receiving emails from it, send an > ema

Re: [akka-user] Re: Seed nodes behavior in 3 node scenario in version 2.5.0

ons like isolation of nodes > > We are using Opendaylight RAFT consensus cluster built atop Akka. > > Regards > Muthu > > > On Tuesday, 5 December 2017 22:35:05 UTC+5:30, Patrik Nordwall wrote: >> >> >> >> On Mon, Dec 4, 2017 at 5:32 PM, Muthukumaran

Re: [akka-user] Re: Seed nodes behavior in 3 node scenario in version 2.5.0

u >> >> >> >> >> >> >> >> -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/ > current/additional/faq.html > >>>>>

Re: [akka-user] BackOff supervisor with reactive-kafka

To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://g

Re: [akka-user] Re: is Akka remoting good for communication to another Akka system ?

There are Cluster aware routers if these components are within the same Akka Cluster. https://doc.akka.io/docs/akka/current/cluster-usage.html#cluster-aware-routers /Patrik lör 2 dec. 2017 kl. 21:02 skrev : > John, > > is *Akka Cluster* supporting load-balancer

Re: [akka-user] Akka Cluster Events Delivery Gauntness

Since these are local messages (in same jvm) you can in practice rely on that they will be delivered. Akka has this disclaimer of at-most-once also for local messages since you might be using a bounded mailbox, or the jvm may crash. In theory you can setup such subscriptions also with remote

Re: [akka-user] Recovery of persistent actor that uses BoundedDequeBasedMailbox

quot;Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/gro

Re: [akka-user] Re: PhiAccrualFailureDetector Constantly Spamming logs but nodes seem unaffected.

ause you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this gro

Re: [akka-user] Distributing lots of large messages to a cluster on startup issue.

to send >>> the http request to of course and make sure the nodes can talk to each >>> other directly without using the load balancer. >>> >>> -- Robert >>> >>> On Thursday, November 30, 2017 at 9:15:03 AM UTC-6, rkuhn wrote: >>>> >>

Re: [akka-user] PhiAccrualFailureDetector Constantly Spamming logs but nodes seem unaffected.

One reason could be that you are sending too large messages. /Patrik tors 30 nov. 2017 kl. 15:32 skrev kraythe : > We are constantly getting messages like this in our logs. > > 2017-11-30 14:28:31,181 [WARN ] [PhiAccrualFailureDetector] >

Re: [akka-user] Distributing lots of large messages to a cluster on startup issue.

Sending 10 MB messages is indeed recipie for trouble. I’d suggest to split the 10 MB into 100 smaller messages and collect, reassembe, them on the receiving side. Perhaps you are fine with loosing such messages since they are periodically published again. Otherwise you could use DistributedData

Re: [akka-user] Akka Typed: ask performance considerations

The implementation is pretty much the same. I wouldn’t be worried about performance for ask, but tell is in general a better fit for actor to actor communication. /Patrik ons 22 nov. 2017 kl. 07:37 skrev Evgeny Veretennikov < evg.veretenni...@gmail.com>: > Classic Akka Untyped docs says: > >

Re: [akka-user] AkkaTyped and Protobuf

, 19. November 2017 16:29:07 UTC+1 schrieb Patrik Nordwall: > >> Serialization is mentioned at the end of this blog post: >> https://akka.io/blog/2017/09/28/typed-cluster >> >> It links to the PingSerializer that illustrates how to use the >> ActorRefResolver. In th

Re: [akka-user] AkkaTyped and Protobuf

Serialization is mentioned at the end of this blog post: https://akka.io/blog/2017/09/28/typed-cluster It links to the PingSerializer that illustrates how to use the ActorRefResolver. In the end the ActorRef is represented as a string in the proto. A more comprehensive serializer example that is

Re: [akka-user] A TestProbe for akka typed

Hi Iain, Many things are missing for testing of Akka Typed, but did you check out: https://github.com/akka/akka/blob/master/akka-typed-testkit/src/main/scala/akka/typed/testkit/scaladsl/TestProbe.scala /Patrik fre 17 nov. 2017 kl. 16:28 skrev Iain Hull : > Hi, > > I am been

Re: [akka-user] Connection state in Artery

TCP <https://github.com/akka/akka/pull/23828> as an alternative to Aeron. That could be a fallback plan if Aeron doesn't fit your needs. > > Kind regards, > > Merlijn > > > > Op zondag 12 november 2017 18:25:16 UTC+1 schreef Patrik Nordwall: >> >> Hi Merlijn, >&

Re: [akka-user] Connection state in Artery

gt;>>>>>>>> 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" group. > To unsubscribe from this group and stop receiving emails from it, se

Re: [akka-user] Performance of Akka-Http 2.5.4

| 57| 76| >>>>> >>>>> >>>>> Round 1 >>>>> >>>>> | metric | nginx | akka-http | colossus | finagle >>>>> | http4s| netty | spring| vertx | &

Re: [akka-user] Detecting, in a sharded, persistent, passivated actor, that no messages are being received.

What about doing it on the read side, that could consume all tagged events. It could keep track of latest event time for each persistenceId and alert if deadline exceeded. /Patrik lör 11 nov. 2017 kl. 16:52 skrev lutzh : > Hi mailing list, > > I was wondering if anyone

Re: [akka-user] Akka stream - Framing with multiple delimiters

gt; wrote: > Oki, i will create a pull request to provide a function, good idea ! > > Le samedi 11 novembre 2017 03:35:28 UTC-5, Patrik Nordwall a écrit : >> >> You could do that by first replacing the various delimiters with one >> common, in a map stage. That said, if this

Re: [akka-user] Help in Running Akka Distributed Data Samples

To compile and run tests you use: sbt test Perhaps start with the Akka Quickstart to get familiar with the basics: https://akka.io/try-akka/ /Patrik tors 9 nov. 2017 kl. 23:40 skrev Nagaraju Ajmeera < ajmeeranagaraj...@gmail.com>: > I am a newbie to the akka framework. I would like to

Re: [akka-user] Akka stream - Framing with multiple delimiters

You could do that by first replacing the various delimiters with one common, in a map stage. That said, if this is typical framing requirement we could perhaps add more power to the framing stage, e.g. a funtion ByteString => Boolean. That would be a good community contribution. /Patrik lör 11

Re: [akka-user] Akka Persistance NullPointerException during actor start up

Isn’t it thrown from PersistentDeviceActor.scala:183 ? /Patrik tis 31 okt. 2017 kl. 20:34 skrev : > Hi Akka gurus, > >1. We use Akka in a production setup >2. We use Cassandra as a back up for akka-persistence. >3. One of the PersistentActors throwed

Re: [akka-user] Debugging postStop cause within a custom stage

Could it be that the materializer is shutting down? “Abrupt termination” /Patrik tors 2 nov. 2017 kl. 04:29 skrev Christopher Hunt : > Hi there, > > I've got a situation where I observe a postStop being called within my > custom GraphStage prior to when I'd expect. I'm sure

Re: [akka-user] missing serialization-bindings for ClusterSingletonProxy$TryToIdentifySingleton$ [akka-cluster-2.5.3]

onal/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" group. > To unsubscribe from this group and stop receiving

Re: [akka-user] Slow subscribers never get invoked after sometime

If these actors blocking while waiting for postgres you might see a starvation issue. All threads in the dispatcher are blocked. You should be able to confirm this with thread dumps, a profiler, or Lightbend’s Thread Starvation Detector. /Patrik mån 30 okt. 2017 kl. 06:56 skrev

Re: [akka-user] Re: Mixing shard regions and proxy to shards regions in the same actor system

/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" group. > To un

Re: [akka-user] Re: Mixing shard regions and proxy to shards regions in the same actor system

cause you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit th

Re: [akka-user] Artery and IPC

ubscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

t;entry is missing") case Some(entry) => if (entry.name == newName) Left("old and new names are equal") else Right(Event.EntryRenamed(id, newName)) } } } > > > On Friday, October 27, 2017 at 12:09:40 PM UTC+

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

Renamed(id: String, newName: String) extends Event > } > } > > > > So for instance after validating command we already have target state, and > as we are using the same code for applying event and validating command, we > don't need to perform it twice, no need in second sanit

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

On Fri, Oct 20, 2017 at 5:29 PM, Yaroslav Klymko <t3h...@gmail.com> wrote: > > On Friday, October 20, 2017 at 4:44:35 PM UTC+2, Patrik Nordwall wrote: >> >> >> >> On Thu, Oct 19, 2017 at 2:52 PM, Yaroslav Klymko <t3h...@gmail.com> >> wrote: >>

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

On Thu, Oct 19, 2017 at 2:52 PM, Yaroslav Klymko <t3h...@gmail.com> wrote: > > > > On Thursday, October 19, 2017 at 9:33:59 PM UTC+2, Patrik Nordwall wrote: >> >> Invalid events must not be stored, because then the actor will not be >> able to recover after a

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

. Also you might just decide to stop the actor in >> case the state is wrong, etc. >> >> On Wednesday, October 18, 2017 at 10:22:12 PM UTC+2, Patrik Nordwall >> wrote: >>> >>> Do you suggest something like this? >>> >>> def immuta

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Vis

Re: [akka-user] Dynamically add routees to or remove routees from a custom Group Router using AddRoutee and RemoveRoutee

Wouldn’t it be easier to implement that as an ordinary Actor, instead of a router? /Patrik tis 17 okt. 2017 kl. 08:16 skrev 김태현 : > Hi, > > I created a custom Group Router (see below), which routes messages based > on the session established on any one of the Routees with

Re: [akka-user] Implements CRDTs conters more than 100 000

Might be some misunderstanding of terminology here. The quote from the documentation is about Distributed Data. In last post I read it as you talk about an actor tree. Anyway, in distributed Data you would use many ORCounterMap as top level entries, and each such map would hold a number of named

Re: [akka-user] How do people handle "delayed" events in eventsByTag in Cassandra?

ain/scala/akka/persistence/cassandra/query/ > EventsByTagPublisher.scala#L141 but just want to double check it does > what I assume it does... > yes > > Regards, > Lutz > > > > On Tuesday, 10 October 2017 13:46:11 UTC+2, Patrik Nordwall wrote: >> &

Re: [akka-user] How do people handle "delayed" events in eventsByTag in Cassandra?

ead 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

Re: [akka-user] Node with ShardCoordinator killing himself

If node B is downed and removed from cluster then the coordinator will stop using B and will allocate shards to other nodes. The coordinator is a cluster singleton and if that node is removed a new coordinator will be started elsewhere with same state. /Patrik tors 5 okt. 2017 kl. 17:01 skrev

Re: [akka-user] Short lived persistent actors and deletion

That is currently not supported but you could contribute that feature to the leveldb plugin. We could use Long.MaxValue as the signal to remove everything. /Patrik fre 6 okt. 2017 kl. 10:44 skrev Ole Hjalmar Herje : > Hi, is it possible to delete persistent actors

Re: [akka-user] Akka Cluster with different seed node sequence

Konrad is right, that is not what you want. I’d like to add two things. You don’t have to start the node listed first in seed-nodes before other nodes. It’s fine to start it afterwards or at the same time. Before joining itself the first seed node tries to join other seed nodes, and that might

Re: [akka-user] Scaladoc missing?

Thanks for reporting. It’s a mistake, we will fix (monday latest). Until then you find close to latest scaladoc at https://doc.akka.io/api/akka/2.5.4/ /Patrik fre 29 sep. 2017 kl. 19:58 skrev Sarah Gerweck : > I was just working on some development and it appears that all

  1   2   3   4   5   6   7   8   9   10   >