[akka-user] Re: Akka Cluster + Leveldb : Persistence failure when replaying events for ...

Hi All, Today I analyzed by consuming cluster events. When first node is down, I got only an UnreachableMember event. I was expecting a MemberRemoved or MemberExited event after UnreachableMember. Is that correct? I didn't get either of them. Is this because I have only two nodes in the

[akka-user] Configurable parallelism/elastic groupBy

I'm sure I've asked this before in numerous ways, but it's still an issue for me. I have an ETL stream that reads per-channel data and writes it to a destination without backpressure. Within a channel, order of writes must be preserved. So I want parallelism between channels, but not within. If

Re: [akka-user] How to use WebSockets with ActorPublisher?

I don't know what your actor publisher was doing inside there. But yeah, this is even better if you can get away without implementing custom stages. On Jul 20, 2016 16:51, "Jakub Liska" wrote: > There seems to be a third alternative to ActorPublisher : > >

Re: [akka-user] Creating Actor w/ Props having Value Class Argument(s)

This basically demonstrates the core of the problem: scala> class Meter(val m: Int) extends AnyVal defined class Meter // in runtime you have *no way* to check if it's an AnyVal extending class or not. We would have to use macros. (scala reflection is a bit iffy...) scala> val m = new Meter(12)

Re: [akka-user] Creating Actor w/ Props having Value Class Argument(s)

Hi Konrad - Could you please give me an example that demonstrates the "so we can't ..."? >AnyVal is a Scala compiler optimisation, so we can't figure out the right constructor (always / safely) in runtime. Thanks On Wednesday, July 20, 2016 at 9:44:33 AM UTC-4, Konrad Malawski wrote: > >

[akka-user] AKKA MicroServices Communication

Hi, as of now what is that people usually do when exposing microservices: 1 - Do you communicate via REST (which can easily be turn somewhat async). 2 - Do you rather use Binary communication ? The point is if microservices allow full blown interoperability by encapsulating how the

[akka-user] Akka Microservice communication

Hi, as of now what is that people usually do when exposing microservices: 1 - Do you communicate via REST (which can easily turn somewhat async). 2 - Do you rather use Binary communication ? The point is if microservices allow full blown interoperability by encapsulating how the the

Re: [akka-user] How to use WebSockets with ActorPublisher?

There seems to be a third alternative to ActorPublisher : Source.actorRef[User.OutgoingMessage](10, OverflowStrategy.fail). mapMaterializedValue the actorRef can be passed to a different Actor that would feed it messages and it would all behave like ActorPublisher, right? On Wednesday, July

Re: [akka-user] How to use WebSockets with ActorPublisher?

RESOLVED : I found a way to create Source and consequently ActorPublisher from ActorRef, so that I can obtain the ActorRef upfront, so instead of : val stateChangeSource: Source[PipelineState, ActorRef] = Source. actorPublisher[PipelineState](StateChangePublisher.props) I do : val

Re: [akka-user] How to use WebSockets with ActorPublisher?

Glad you resolved it. Related hint is that one really really shouldn't be using ActorPublisher, you should build stages from GraphStage instead, the reason is that a) ActorPublisher is not fusable b) it's really hard to actually implement a *correct* Publisher (even with ActorPublisher's help).

Re: [akka-user] How to use WebSockets with ActorPublisher?

Could you provide a sample snippet that we could help out with? Context helps to get quicker help. -- Konrad `ktoso` Malawski Akka @ Lightbend On 20 July 2016 at 16:03:30, Jakub Liska (liska.ja...@gmail.com) wrote: hey, I hit a deadend with combination

[akka-user] How to use WebSockets with ActorPublisher?

hey, I hit a deadend with combination of Websockets and ActorPublisher because the TextMessage expects Source and one can obtain the underlying ActorRef from ActorPublisher only by materializing it :

Re: [akka-user] Creating Actor w/ Props having Value Class Argument(s)

Because the type (wrapper) is not there at runtime. AnyVal is a Scala compiler optimisation, so we can't figure out the right constructor (always / safely) in runtime. A resolution would be to "if thing has one field, and that value matches we use that field" which could lead to very weird

[akka-user] Creating Actor w/ Props having Value Class Argument(s)

Looking at the Akka docs for creating an Actor: The recommended approach to create the actor Props is not supported for cases when the actor constructor takes value classes as arguments. Please explain the "is not supported ..."

Re: [akka-user] Re: Make HTTPS request using akka-http to jenkins server

Pretty sure there's a stack trace there though? What happens on default settnigs – dont manually set the JVM default context. -- Konrad `ktoso` Malawski Akka @ Lightbend On 20 July 2016 at 14:13:39, Ajinkya Shukla (ajinkyashukl...@gmail.com) wrote: I get

[akka-user] Re: Make HTTPS request using akka-http to jenkins server

I get the following exception in DEBUG mode. disconnected after javax.net.ssl.SSLHandshakeException: General SSLEngine problem On Wednesday, July 20, 2016 at 8:01:04 AM UTC-4, Ajinkya Shukla wrote: > > How can i make the following HTTPS request using akka-http to a jenkins > server? > > curl

Re: [akka-user] Make HTTPS request using akka-http to jenkins server

Please read: http://doc.akka.io/docs/akka/2.4.8/scala/http/client-side/client-https-support.html#clientsidehttps and: http://typesafehub.github.io/ssl-config/ Note that you're using SSLContext.getDefault, pretty sure that's not a good idea for you. Also, what's the error? Please post the

[akka-user] Make HTTPS request using akka-http to jenkins server

How can i make the following HTTPS request using akka-http to a jenkins server? curl -v -k --user "$USERNAME:$API_TOKEN" https://HOSTNAME.com/api/json The curl produces the following HTTPS request: Connected to HOST.com * TLS 1.2 connection using TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 * Server