Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:38
    patriknw commented #29767
  • Oct 26 2020 07:07
    patriknw commented #29765
  • Oct 26 2020 06:56
    patriknw commented #25468
  • Oct 26 2020 06:30
    wtfiwtz starred akka/akka
  • Oct 26 2020 04:31
    YunSeongKim7 starred akka/akka
  • Oct 25 2020 16:21
    nitikagarw commented #25468
  • Oct 25 2020 09:22
    fubiao starred akka/akka
  • Oct 25 2020 05:09
    saguywalker starred akka/akka
  • Oct 24 2020 21:47
    tt4n starred akka/akka
  • Oct 24 2020 21:20
    akka-ci commented #29672
  • Oct 24 2020 21:05
    dope9967 commented #29672
  • Oct 24 2020 21:03
    akka-ci commented #29672
  • Oct 24 2020 21:03
    akka-ci unlabeled #29672
  • Oct 24 2020 21:03
    akka-ci labeled #29672
  • Oct 24 2020 20:44
    dope9967 synchronize #29672
  • Oct 24 2020 20:31
    akka-ci unlabeled #29672
Sven
@iosven
To learn about the Actor Model in general check out https://en.wikipedia.org/wiki/Actor_model
Konrad `ktoso` Malawski
@ktoso
akka in action is a good book
vikramdarsi
@vikramdarsi
@ktoso Where do we specify which is the snapshot store that we are using? is that in akka.conf or by means of program, if so, which is that class ?
in akka persistence
Konrad `ktoso` Malawski
@ktoso
application conf, read the persistence docs please.
Albert Serrallé Ríos
@aserrallerios
having problems implementing a custom serializer for akka-remote, I want to implement a Serializer extending SerializerWithStringManifest with ByteBufferSerializer but the hint found in the javadoc to do so https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/serialization/Serializer.scala#L157 points me to a private[akka] class that I cannot use, so I don't know how to implement the override def toBinary(o: AnyRef): Array[Byte] method :(
Konrad `ktoso` Malawski
@ktoso
it's just a pool of buffers, nothing that you need to implement this
Konrad `ktoso` Malawski
@ktoso
mima filters don't work in http? hm.......
maybe rebase hm
ah wrong file
also quite a dance nowadays ;)
also no...
Konrad `ktoso` Malawski
@ktoso
hm... really, ignores the filter
:|
ok, very weird... why do I add filters for spray json marshallers to the akka-http mima file...
well, it works
SemanticBeeng
@SemanticBeeng
@jrudolph can Akka-http be used to replace Play! from a architecture and reliability standpoint?

Ran into this issue due to a runtime conflict between Netty as used by Play! 2.5 and Netty as used by ElasticSearch 5.1

sksamuel/elastic4s#666

see my summary here

https://github.com/sksamuel/elastic4s/issues/666#issuecomment-271137337

Refactored the code to multi-modules like in https://github.com/adrianhurt/play-multidomain-seed in order to isolate ES code to a module.

But cannot find a way to run the ES module in a separate classloader so it does not conflict with Play.

All I need is "REST for actors". Kindly advise.
Johannes Rudolph
@jrudolph
@SemanticBeeng if you just need REST for actors, akka-http may be for you
but it's not a webframework like play
SemanticBeeng
@SemanticBeeng
understood, functionally not the same thing
but to implement microservices probably enough. even best?
Johannes Rudolph
@jrudolph
let's say functionally related but not the same scope
yes, if you want to provide an HTTP interface to already (maybe already existing) akka services, then that's what akka-http is for
SemanticBeeng
@SemanticBeeng
I would rather "find a way to run the ES module in a separate classloader so it does not conflict with Play." - is there such a way? or all modules are loaded in the same/shared application classloader?
Johannes Rudolph
@jrudolph
hmm, that's rather a play question it seems
SemanticBeeng
@SemanticBeeng
right. thank you much!
Patrik Nordwall
@patriknw
@aserrallerios Here is a better example of the ByteBufferSerializer, without the pool http://doc.akka.io/docs/akka/2.4/java/remoting-artery.html#ByteBuffer_based_serialization
Albert Serrallé Ríos
@aserrallerios
// in production code, aquire this from a BufferPool :P
should I just copy-paste the definition of akka.io.DirectByteBufferPool?
Konrad `ktoso` Malawski
@ktoso
or just new Array{} really ;)
pool is faster, you can steal if you want, but really it's not needed ;)
Albert Serrallé Ríos
@aserrallerios
@ktoso ok! maybe I'm being a bit paranoid here lol
drewhk
@drewhk
also, that pool is not optimal. The Artery code is better in that regard
Albert Serrallé Ríos
@aserrallerios
what do you mean? what Artery code in particular?
daniel-element-analytics
@daniel-element-analytics
Does anyone know what the migration story is on Spray's Deserializer code? https://github.com/spray/spray/blob/master/spray-httpx/src/main/scala/spray/httpx/unmarshalling/Deserializer.scala
Having a hard time finding any related code in akka-http. (And Konrad, I'll take note of these migration hiccups and work on writing them up for the migration guide.)
Konrad `ktoso` Malawski
@ktoso

(And Konrad, I'll take note of these migration hiccups and work on writing them up for the migration guide.)

awesome, thanks a ton

dont know about deserializer hm, open a thread if still stuck please
Josh
@joshlemer
Do you think it would be a good idea to add a flow stage like TakeUntil(p: A => Boolean)? For example
Source(1 to 10).takeUntil(_ >= 5) // equivalent to Source(1 to 5)
It would be sort of similar to .takeWhile(p: A => Boolean), except it would be inclusive, not exclusive
vikramdarsi
@vikramdarsi
Hi , In akka cluster, election will happen again only when the leader node goes down right?
Patrik Nordwall
@patriknw
For the leader that perform some cluster memberhip actions there is no real election. Leader is the node with lowest address, excluding unreachable nodes (and a few more rules). The leader will only act when there is so called convergence (no unreachable, and all nodes have seen current state)
Why do you ask? The concept of the leader is rather internal and should normally not be used by applications.
vikramdarsi
@vikramdarsi
we are planning to set virtual ip using keepalived process
Patrik Nordwall
@patriknw
Ok, i don't know what that means. What is the property you are looking for. Running something on only one node?
vikramdarsi
@vikramdarsi
Our deployment would be a 3 node cluster, of which one would be the leader. say for some reason, if the follower node goes down, will the election happen again?
if not, cluster runs smoothly with just 2 nodes