Re: [akka-user] Re: Akka Http 10.1.0 Released

Excellent, thanks for reporting back :) -- Konrad Malawski On March 10, 2018 at 15:52:46, Gavin Baumanis (gavinbauma...@gmail.com) wrote: > Congratulations to all! > Thanks very much for your ongoing efforts! > > I have updated our application to the new version and all m

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

; Thanks Konrad. > What I was interested in was what use cases both Spark and Flink used > Actors for specifically. Are there any notes/docs around those that anyone > knows of? > > > > On Monday, 19 February 2018 07:33:43 UTC+5:30, Konrad Malawski wrote: >> >>

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

Hi there, There's been some confusion about how Spark used Akka, so let's clear that up first: It wasn't really core to any of the operations or core of Spark, and was used only to orchestrate some things, it was using raw Akka Remoting (which is discouraged, use Cluster instead due to the

Re: [akka-user] Cancel Actor job

-- Konrad Malawski On January 26, 2018 at 3:56:05, Richard Gong (gong...@gmail.com) wrote: > I'm newbie in Akka. Here's one thing I'm trying to achieve, a simple job > manager. There are jobs involving SQL queries and CPU intended computation. > The jobs should be cancellable while they'r

Re: [akka-user] Update Aeron to 1.7?

It already is updated in the sources since some weeks: https://github.com/akka/akka/blob/master/project/Dependencies.scala Await an upcoming release with it. Happy new year! -- Konrad Malawski On December 31, 2017 at 0:12:05, Vishnu Vardhan (vardh...@gmail.com) wrote: > Hi Guys > >

Re: [akka-user] Turn a flow to a route

(My bad about reading your statement, you wrote it right — it is true though that the inverse conversion simply is not possible in general) -- Konrad Malawski On December 15, 2017 at 12:51:34, haghard (haghar...@gmail.com) wrote: > Hello everybody, > akka-http has a way to turn a

Re: [akka-user] Turn a flow to a route

I think you’re misunderstanding something. Akka HTTP can convert a route to a Flow (the inverse of what you said), and an opposite transformation is not in general possible. What specifically are you trying to achieve? -- Konrad Malawski On December 15, 2017 at 12:51:34, haghard (haghar

Re: [akka-user] Is it easy to use akka-http to build ...?

Please search the docs for “websocket” it’s well documented. Short reply since in meetings now ;-) Glad you enjoyed the VJUG talk! -- Konrad Malawski On December 8, 2017 at 12:58:21, Thai (lgoptimusv...@gmail.com) wrote: > And how about the websocket? > > On Thursday, December 7, 2

Re: [akka-user] Akka persistence plugin TCK test on java via maven - how to trigger the test suite ?

This is resolved by https://github.com/ktoso/akka-persistence-tck-testing-from-java/pull/2 Have a look there. Happy hakking On Thu, Nov 23, 2017 at 7:46 AM, mahmoud romeh wrote: > Hi All , > > I have referenced the documentation for how to test new akka persistence >

Re: [akka-user] Akka JDK 9 module support

to start adopting modules into your build btw. -- Konrad Malawski On November 6, 2017 at 6:42:44, Grzegorz Olechwierowicz ( thertan...@gmail.com) wrote: > Hello, > > I'm trying to add akka to java 9 project. > What do I have to require in module-info.java to use Akka with JDK 9? I >

Re: [akka-user] Akka FSM, Persistence and multiple instances

entities. -- Konrad Malawski On October 28, 2017 at 17:44:08, wapgui (torsten.schm...@wapgui.com) wrote: > I'm closing the actors after each request and recreate with the same uuid. > > Am Samstag, 28. Oktober 2017 10:41:28 UTC+2 schrieb Konrad Malawski: >> >> Are you cre

Re: [akka-user] Akka FSM, Persistence and multiple instances

will be guaranteed by sharding then. -- Konrad Malawski On October 28, 2017 at 17:34:12, wapgui (torsten.schm...@wapgui.com) wrote: > Hi, > > I've built a FSM using Akka FSM and Persistence to a Percona cluster in > near cloud. > Running this environment in a single instance causes no

Re: [akka-user] Re: Spray->Akka-Http Migration - seeing high 99th percentile latencies post-migration

When asking about performance and benchmarks always include specific numbers, code, and benchmark methodology otherwise it’s just guessing and inventing numbers and reasons. Thanks -- Konrad Malawski On October 13, 2017 at 5:36:06, Gary Malouf (malouf.g...@gmail.com) wrote: > To be cl

Re: [akka-user] [akka-streams] Shared Materializer in akka extensions

Though I'm not sure it actually is as important to have the users and your extension share a materializer by the way. What is it you're building exactly? Keeping one materializer in the extension could be totally fine as well. On Sat, Sep 30, 2017 at 11:18 AM, Konrad “ktoso” Malawski <

Re: [akka-user] Akka Http memory leak suspect

evaluationService) > onSuccess(resultF) { result => > complete(result) > } > } > } > } > } > > > > > On Monday, 25 September 2017 11:01:08 UTC+2, Konrad Malawski wrote: >> >> What are you doing in the app ;-) >> Sounds to me li

Re: [akka-user] Speeding up actor system boot time in testing environment

Why do you need to start new systems? -- Konrad `ktoso` Malawski Akka @ Lightbend On 27 August 2017 at 16:59:02, Jakub Liska (liska.ja...@gmail.com) wrote: Hey, actor system boot time matters in distributed systems integration testing, otherwise

Re: [akka-user] akka-streams: what causes the downstream to be "cancelled"/onDownstreamFinish called?

> Thanks, > Josh > > > > On Monday, June 26, 2017 at 7:25:38 PM UTC+1, Konrad Malawski wrote: >> >> Could you share the full snippet? >> The code as pasted above would not cancel (downstream cancels, but a >> Sink.ignore never would cancel). >> A

Re: [akka-user] Order of log lines is mixed when 3rd party logs write directly to SLF4J

You can always just us slf4j directly - use an async appender in the impl (logback2 AFAIR provides one and others as well) and you're good. There's no requirement to use ActorLogging, we only have it to not depend on a specific logging API in akka-actor itself. -- Konrad `ktoso` Malawski Akka

Re: [akka-user] No matching constructor found

Arun, please do not post the same question to 3 different channels when you already were given a response. If you need to re send a question, please at least link back to where you asked already. This was answered in:

Re: [akka-user] Access to the underlying java.util.concurrent.ExecutorService from an Akka Dispatcher

Lightbend monitoring just-works™ and does this for you if you're interested: http://developer.lightbend.com/docs/monitoring/latest/instrumentations/akka/dispatchers.html You can get the information, it's not hidden per-se, however I'm not sure how well open source alternatives extract the

Re: [akka-user] Akka stream - Source of http response.

Hi Alejandro, I don't get the question - could you rephrase it a bit (more details)? An HttpRequest simply contains a Source[ByteString, _] and that "just works"™. -- Konrad `ktoso` Malawski Akka @ Lightbend On 26 May 2017 at 00:21:38, Alejandro Merchan

[akka-user] ANNOUNCE: New documentation theme and Akka HTTP 10.0.7 Released

Dear hakkers, We are proud to announce Akka Http 10.0.7, which is the seventh release of the Akka Http 10.0 series. This is a regular maintenance release that contains several maintenance fixes, improvements and features that are a result of our ongoing collaboration with the Play team towards

Re: [akka-user] ANNOUNCE: New Akka documentation, website and Akka 2.5.2 released

Hi Lee, RSS works for me, do you use this feed: http://akka.io/rss.xml ? -- Konrad `ktoso` Malawski Akka @ Lightbend On 25 May 2017 at 10:06:00, Lee_T (lee.tibb...@gmail.com) wrote: New blog website looks spiffy. RSS feed appears broken. Is it intended

Re: [akka-user] ANNOUNCE: New Akka documentation, website and Akka 2.5.2 released

We believe it may still be indexing the new pages; If that's not the case we'll investigate deeper shortly :-) Thanks for reporting -- Konrad `ktoso` Malawski Akka @ Lightbend On 24 May 2017 at 20:04:18, Richard Rodseth (rrods...@gmail.com) wrote: Looks

Re: [akka-user] How to load dataase records into ram by akka and java

You'll still of course use some jdbc driver to pull the data out. You can use Slick to get a Reactive Stream which you can easily consume using Akka Streams: Source.fromPublisher(db.stream(strm.result)) which you could then use mapAsync or other operators on to make it process more at the same

Re: [akka-user] Re: Actor per process or service ?

I see, well then it's just about how constrained you want the parallelism basically which starts to sound like you'd know more about since the actual operations they will do are very tied to what your app actually does hmm -- Konrad `ktoso` Malawski Akka @ Lightbend

Re: [akka-user] Actor per process or service ?

I did a similar thing in the past, however we were able to not poll, by using https://git-scm.com/book/gr/v2/Customizing-Git-Git-Hooks on the server - sure you can't do that? If it's a hosted repo perhaps they provide other hooks? In general though - the question is how many processes doing

Re: [akka-user] Could not resolve substitution to a value: ${akka.stream.blocking-io-dispatcher}

Hi there, > case x => MergeStrategy.first is wrong. Configuration must be concated - so all reference.conf and application.conf must be concated together. -- Konrad `ktoso` Malawski Akka @ Lightbend On 18 May 2017 at 14:53:55, tj5...@tutanota.com

Re: [akka-user] How to map unstructured Json to a case class in Akka-Http

Please read the docs about json support: http://doc.akka.io/docs/akka-http/current/scala/http/common/json-support.html You're likely missing SprayJsonSupport -- Konrad `ktoso` Malawski Akka @ Lightbend On 13 May 2017 at 10:47:51,

Re: [akka-user] Use case for a customized dispatcher

You likely don't need to, ever. In fact, we won't be supporting writing your own in Akka Typed. -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 May 2017 at 18:20:06, Dai Yinhua (yhdai.2...@gmail.com) wrote: I don't know, I'm reading through Akka

Re: [akka-user] Use case for a customized dispatcher

Hi there, I don't think you need to write a custom dispatcher - do you have evidence that you need to implement your own? -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 May 2017 at 18:00:14, Dai Yinhua (yhdai.2...@gmail.com) wrote: Hi Akka team, In

Re: [akka-user] Restart stream with backoff

The hosting within an Actor is a perfectly fine and valid solution IMHO. On Tue, May 9, 2017 at 4:04 PM, 'Michal Borowiecki' via Akka User List < akka-user@googlegroups.com> wrote: > Sounds like what could help in your organization is using a higher-level > abstraction, such as Lagom. > > You

Re: [akka-user] Confusion in documentation regarding HTTPS support in Akka HTTP

TTPS setting on this speficic request, all others should have another setting. On Monday, May 8, 2017 at 8:19:19 AM UTC+2, Konrad Malawski wrote: > > It's plain Java, configure the SSLContext as usual and provide it to the > HttpsConnectionContext. > > -- > Konrad `ktoso` Malawski >

Re: [akka-user] Confusion in documentation regarding HTTPS support in Akka HTTP

to set HTTPS settings on the Http().singleRequest? The docs says it uses the default but i just want to set the HTTPS setting on this speficic request, all others should have another setting. On Monday, May 8, 2017 at 8:19:19 AM UTC+2, Konrad Malawski wrote: > > It's plain Java, configure the S

Re: [akka-user] Lookup custom header in response headers

com> wrote: > Okay, that makes sense. Thanks Konrad. > > On Sun, May 7, 2017 at 10:27 PM, Konrad Malawski < > konrad.malaw...@lightbend.com> wrote: > >> To clarify: You'll notice that it does actually work in the routing DSL, >> even if you supply a RawHead

Re: [akka-user] Confusion in documentation regarding HTTPS support in Akka HTTP

a case like this? On Monday, May 8, 2017 at 8:09:26 AM UTC+2, Konrad Malawski wrote: > > My guess right now is that they do the same thing but the part under > SSL-Config sets up the system default HttpsContext, is this correct? > > Yes, that's the case. > > SSLConfig is me

Re: [akka-user] Confusion in documentation regarding HTTPS support in Akka HTTP

My guess right now is that they do the same thing but the part under SSL-Config sets up the system default HttpsContext, is this correct? Yes, that's the case. SSLConfig is merely a helper utility you can use to easily set up things. You can not use it if you don't want to. -- Konrad `ktoso`

Re: [akka-user] Lookup custom header in response headers

custom header in the response. If the response contains more than one custom headers, resp.header[RawHeader] will return first custom header. I'm using akka-http 10.0.6 and akka 2.5.1. Best, Marco On Monday, April 24, 2017 at 5:46:13 AM UTC-4, Konrad Malawski wrote: > > Hi Kyrylo, > Would you m

Re: [akka-user] akka-http Client-Side HTTPS Support MITM Warning

Hi Ferenc, please do always read the latest docs - this is an ancient note you stumbled upon. "1.0" refers to a version released back in July 2015 (!), at which time we did not have the certificate checking implemented. By now it is, and the note is gone from the docs:

[akka-user] ANNOUNCE: Akka HTTP 2.4.11.2 Security Patch Released

Dear hakkers, We announce the immediate availability of the second security patch for the experimental Akka HTTP that was part of the 2.4.x development series. It contains an important security fix for a vulnerability that affects all Akka HTTP applications that use the routing DSL. The

[akka-user] ANNOUNCE: Akka-Http 10.0.6 Security Update Released

Dear hakkers, We are proud to announce Akka Http 10.0.6, which is the sixth release of the Akka Http 10.0 series. It contains an important security fix for a vulnerability that affects all Akka HTTP applications that use the routing DSL. The vulnerability allows a remote attacker to crash an

Re: [akka-user] Akka Flow map from X to X, the materialize

A flow is not something you can run - it's defined as "one open input, one open output". What the method fromSinkAndSource builds is like a flow made from two discrete parts. Imagine that it's input will be drained to the given sink, and it's output IS the source you gave it. If you just want to

Re: [akka-user] Akka-streams supervision: best practices

Hi Alexander, since you asked the same question on the issue tracker at the same time allow me to link those and let's continue the discussion here if you want; https://github.com/akka/akka/issues/21192#issuecomment-298806620 Firstly: I don't think that's entirely true. Existing supervision

Re: [akka-user] Graph materialized value of websocket upgrade

, 2017 at 12:42:43 PM UTC+2, Konrad Malawski wrote: > > Sorry for the brief response, quite a lot of text in there :) > > Yeah, mapMaterializedValue is a way to getting it out and side effecting > it into somewhere. > > -- > Konrad `ktoso` Malawski > Akka <http://

Re: [akka-user] Akka and RDMA

I'd read that note as "it is possible to put it onto RDMA" :-) -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 May 2017 at 19:35:31, Marc Christoph (facelessto...@gmail.com) wrote: Apologies, Michal. The resource containing the (brief) mention of RDMA

Re: [akka-user] Graph materialized value of websocket upgrade

Sorry for the brief response, quite a lot of text in there :) Yeah, mapMaterializedValue is a way to getting it out and side effecting it into somewhere. -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 May 2017 at 19:35:32, Mathieu Bruyen

Re: [akka-user] Akka REST API - Path Param vs Headers

. -- Konrad Malawski On April 29, 2017 at 23:19:30, Arun (sethia.a...@gmail.com) wrote: > Hi, > > I am using Akka HTTP routes to define Akka HTTP REST end points. > > Are there any guidelines that says "we should not use path param, and try > to use header", if yes

Re: [akka-user] akka stream kafka newbie question

A Sink is a Graph; as is a Flow, and a Source - they're all graphs, of a specific shape. Here, the method takes a Graph

Re: [akka-user] Actor name is not unique after termination when running from unit tests

In other words, only the *parent* of the stopped actor can safely "aha! I've seen it stopped, so I'll start a new one with the same name". This is documented behavior in the Actor docs :) -- Konrad `ktoso` Malawski Akka @ Lightbend On 28 April 2017 at

Re: [akka-user] Akka HTTP/JSON: Rejecting requests with unknown fields

.io> @ Lightbend <http://lightbend.com> On 27 April 2017 at 01:59:42, Henrik Nordvik (henri...@gmail.com) wrote: On Wednesday, March 29, 2017 at 7:13:28 AM UTC-4, Konrad Malawski wrote: > In principle sure, though not on anyones roadmap nowadays. > You could contribute such a th

Re: [akka-user] Akka HTTP client - Advice for executor context

Dispatcher (executor) is mostly important if you're doing bad things on it - like blocking on responses for example. If you're handling things in async / reactive ways the default akka dispatcher is fine most of the time, just don't block on it (read this:

Re: [akka-user] Relative URL when using Http Request?

apps. Instead of doing requests to yourself I would recommend sharing code or methods inside the implementation. -- Konrad Malawski On April 25, 2017 at 11:31:33, todd.f@gmail.com (todd.f@gmail.com) wrote: > Hi, > > I'm using akka-http to build a restful api. In one route

Re: [akka-user] Handling spray.json.DeserializationException in akka-http route

Hi there, Read the documentation about exception handlers in Akka http. That should get you what you want -- Konrad Malawski On April 25, 2017 at 8:13:24, Andras Szerdahelyi ( andras.szerdahe...@gmail.com) wrote: > ( I apologize for the re-post if you've seen this under the akka / > akk

Re: [akka-user] Lookup custom header in response headers

Hi Kyrylo, Would you mind sharing your code for the transaction id header? That way of extracting a header does work, and I've added a test as we were missing that specific style actually: https://github.com/akka/akka-http/pull/1047 I suspect you may have done something wrong in your header

Re: [akka-user] Akka websocket server-push model (server sends messages to client)

Hi Andy, further details on how (where to which client) you want to push would be helpful for my understanding (and future development). We have developed an example app recently that does such a thing, it registers "drones" in an actor that keeps track of them by ID, and allows the server

Re: [akka-user] FileIO.toFile does not truncate existing file

Great catch, you're absolutely right. Please open a PR, thanks! -- Konrad Malawski On April 21, 2017 at 22:39:28, Patrik Nordwall (patrik.nordw...@gmail.com) wrote: > Wow, not truncating would be very confusing. Please open a PR. > > On Fri, Apr 21, 2017 at 3:36 PM, Enno <enno.ru.

Re: [akka-user] GraphStage instead of ActorPublisher/ActorSubscriber

I would not call it a stub... it's basically all you need. I see however that you're asking for extend documentation with examples in that section - would you mind opening a ticket on http://github.com/akka/akka about that (Add more examples for integrating with Actors in docs section ...)?

Re: [akka-user] Re: Has akka-http has abandoned per request actors in favor an anti-pattern DSL?

For starters: It's fine if your preference is to not use the DSL, no one will force you to; and that's also the reason the DSL is a separate artifact. Also, your route here is definitely multiple things and those should be split up. Why make one huge route, make many vals with the small pieces

Re: [akka-user] GraphStage instead of ActorPublisher/ActorSubscriber

Implement the logic within the GraphStage. It basically behaves like an Actor (but can be fused too). -- Konrad `ktoso` Malawski Akka @ Lightbend On 19 April 2017 at 12:46:23, Richard Rodseth (rrods...@gmail.com) wrote: I've read that ActorPublisher and

Re: [akka-user] Shutting down a ShardRegion

What you describe is exactly a feature we just rolled out in Akka 2.5.0 :-) Docs here: http://doc.akka.io/docs/akka/2.5/scala/actors.html#Coordinated_Shutdown It also handles other parts of Akka, such as cluster singletons, Akka HTTP and more. Akka 2.5 is binary compatible with 2.4 (except if a

Re: [akka-user] akka-http and jackson marshaller/unmarshaller

Why are you mixing javadsl with scaladsl. Javadsl is clearly not intended for Scala users :-) Just use https://github.com/hseeberger/akka-http-json which provides jackson as one of the impls. -- Konrad `ktoso` Malawski Akka @ Lightbend On 17 April 2017

Re: [akka-user] Akka streams: Why use .named()?

Not sure what you're referring to? Yes it does/would come into play when we draw stuff. On Apr 13, 2017 03:07, "Sean Callahan" wrote: > Okay, that's kinda what I figured. Will the named attribute come into play > at all with some of the graphing Ive seen a little of

Re: [akka-user] Akka streams: Why use .named()?

Better debugability - names can show up in logging / failures / inspections of graphs etc. -- Konrad `ktoso` Malawski Akka @ Lightbend On 13 April 2017 at 02:59:49, Sean Callahan (sean.callahan...@gmail.com) wrote: While browsing the akka docs I came

Re: [akka-user] TcpIdleTimeoutException for Http request

Well it seems no data is flowing on the connection "the request". Please provide sample code; I think you may be misunderstanding the lifecycle of a connection a bit? -- Konrad `ktoso` Malawski Akka @ Lightbend On 12 April 2017 at 13:08:55, Johnson Liu

Re: [akka-user] TcpIdleTimeoutException for Http request

Hi there, timeouts are documented in depth here: http://doc.akka.io/docs/akka-http/10.0.5/scala/http/common/timeouts.html Basically idle timeouts means a connection is hanging around doing nothing - no data being sent either way, so it should be torn down - we signal this via this timeout. --

Re: [akka-user] [Akka-Http] Consuming request entity multiple times

The reason it worked for the small payload is an optimisation done by Akka http, if it detects the entity will be a small "strict" one, the entire thing is loaded. So such payload can be materialized twice. We hope to make this more configurable in the future, and help with those scenarios even

Re: [akka-user] Re: WebSocket with Akka Streams

Correct this works to append to files. Please note that if multiple threads (incoming streams) write to the same file appending you could get messy data out of that tough. On Apr 1, 2017 12:28, "Julian Howarth" <10.howa...@gmail.com> wrote: > You can get the Sink to append to file by passing in

Re: [akka-user] Catching exceptions in actor receive?

Read about supervision, one of the strategies is Resume. Try/catch is also fine, but mostly if you want to do stuff with the exception other than log it. E.g. Reply that things failed. On Apr 1, 2017 07:58, "kraythe" wrote: > I have an actor that I would like to not fail.

Re: [akka-user] Can Akka Actors be considered as green threads?

Actors are objects that are scheduled on Kernel threads using ForkJoin Pool? That's how they're implemented yeah - tasks submitted to a pool. But that misses all the things which make the model useful: isolation and location transparency (the most important one!). So you don't care if an actor

Re: [akka-user] SOF question on debugging, breakpoints, timout and dead letters

Akka channel and not a commercial channel for advertising Lightbend, or is it ? On Fri, Mar 31, 2017 at 12:40 PM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > Hi Jozsef, when cross-posting at least take the effort to copy the > message... > Just posting more links via more channels seems

Re: [akka-user] SOF question on debugging, breakpoints, timout and dead letters

Hi Jozsef, when cross-posting at least take the effort to copy the message... Just posting more links via more channels seems very "nagging". If you want ASAP answers we offer commercial support, otherwise please be nice and patient when asking the community for help. Thanks for your

Re: [akka-user] Need a simple example on how to consume a HTTP Service with Json unmarshalling

interested. The solution is indeed much easier than I thought! Thanks again for your help! Yeah, I know the documentation is there, but everything is a little bit hard to follow. have a good one! :) Am Donnerstag, 30. März 2017 14:37:52 UTC+2 schrieb Konrad Malawski: > > >

Re: [akka-user] Need a simple example on how to consume a HTTP Service with Json unmarshalling

On 30 March 2017 at 14:28:34, Mo Batista (mounir3...@gmail.com) wrote: I'm new to Akka-Http please bear with me. Hello Mo and welcome to Akka :- What I'm trying to do is 1. Connect to a Restful service 2. Unmarshall the json payload into the following case class structure It's as simple as

Re: [akka-user] Akka HTTP/JSON: Rejecting requests with unknown fields

tbend.com> On 28 March 2017 at 23:57:05, Alan Burlison (alan.burli...@gmail.com) wrote: On 28/03/2017 22:51, Konrad Malawski wrote: > Your unmarshaller (you did not say what you're using), should be configured > to blow up then. The default Akka/HTTP one, namely Spray/JSON. > The spra

Re: [akka-user] Akka HTTP/JSON: Rejecting requests with unknown fields

Your unmarshaller (you did not say what you're using), should be configured to blow up then. The spray-json one can not do that. -- Konrad `ktoso` Malawski Akka @ Lightbend On 28 March 2017 at 23:37:57, Alan Burlison (alan.burli...@gmail.com) wrote: I'm

Re: [akka-user] Akka Stream- How to use Slick as Subscriber(Sink) to data into Database.

AFAIR they have not implemented streaming inserts. Just data.mapAsync()(insert). -- Konrad `ktoso` Malawski Akka @ Lightbend On 28 March 2017 at 10:19:50, DEEPAK GUPTA (vnitdee...@gmail.com) wrote: Akka Stream- How to use Slick as Subscriber(Sink) to

Re: [akka-user] Can we use activator for Spark projects?

the configs at the appropriates places and so on. I know that you mentioned activator is going to go away. How about SBT? is that there to stay? Thanks! On Mon, Mar 27, 2017 at 3:48 AM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > Activator is just a sample-app tool to try out Scala a

Re: [akka-user] Can we use activator for Spark projects?

Activator is just a sample-app tool to try out Scala and tutorials etc. I guess it could maybe work with Spark for a demo but I would not recommend it... Use a real IDE :) -- Konrad `ktoso` Malawski Akka @ Lightbend On 27 March 2017 at 12:46:17, kant

Re: [akka-user] How to avoid saturation in Akka HTTP (latency spikes)?

for it a on a phone at friends place :) -- Konrad Malawski On 25 March 2017 at 23:52:06, Manuel Darcemont (manuel.darcem...@gmail.com) wrote: > Ok, that's what I thought, I only wanted to be sure about it. So I guess > integrating Slick 3 to benefit from it's non-blocking API would be

Re: [akka-user] Does Event Bus require Publisher and Subscriber to be started in certain order?

There is not. EventStreams do not buffer. You can just build such a thing yourself using Actors if you need to though, it's pretty simple - one actor that gets/buffers/relays messages - done. -- Konrad `ktoso` Malawski Akka @ Lightbend On 23 March 2017 at

Re: [akka-user] Cannot use a method returning play.mvc.WebSocket[?0] as a Handler for requests

That's a Play question, so please ask in the Play community: https://groups.google.com/forum/#!forum/play-framework This forum is called Akka-user, so yeah, we talk about Akka specifically here ;-) -- Konrad `ktoso` Malawski Akka @ Lightbend On 23 March

Re: [akka-user] Does Activator require SBT ? Can it work with gradle?

replacement? Any pointer on the web I can follow? On Wednesday, March 22, 2017 at 4:32:35 AM UTC-7, Konrad Malawski wrote: > > Thanks! > > It does require it. It is only a getting started tool so you should not > really care. Your normal development you do in whichever thing y

Re: [akka-user] Does Activator require SBT ? Can it work with gradle?

Thanks! It does require it. It is only a getting started tool so you should not really care. Your normal development you do in whichever thing you want. It is also being deprecated in favour of new tools we're working on at Lightbend. -- Konrad `ktoso` Malawski Akka @ Lightbend

Re: [akka-user] How to group a list of actors in Akka?

On 22 March 2017 at 03:06:34, kant kodali (kanth...@gmail.com) wrote: I think I understand it better from what you said. I guess I don't have separate parent for each group therefore I was looking to see how to group the child actors but anyways since it is not the standard approach from what you

Re: [akka-user] How to group a list of actors in Akka?

As such, no -- there's no formal "group" concept like this, although you could construct it manually yourself. There is "all children of given actor" which is accessible by context.children() inside an Actor. -- Konrad `ktoso` Malawski Akka @ Lightbend

Re: [akka-user] MergePreferred with different priorities on all inlets

No, feel free to build a stage like that and contribute to akka-stream-contrib - would be nice :) -- Konrad `ktoso` Malawski Akka @ Lightbend On 20 March 2017 at 15:23:03, Sergey Sopin (sopin1...@gmail.com) wrote: Hi, Is there any way to set different

[akka-user] ANNOUNCE: Akka HTTP 10.0.5 Released!

Dear hakkers, we — the Akka HTTP committers — are happy to announce Akka Http 10.0.5, which is the fifth maintenance release of the Akka Http 10.0 series. It is primarily aimed at stability aligning the internals with the upcoming Akka 2.5 release. These steps are also the groundwork to enable

Re: [akka-user] How akka cluster become network partition

Network is network. Does not matter if something is close or far. This applies to all distributed systems or databases. Just some prefer to not tallboy about it and then you notice once it's too late and you're screwed ;-) In All we prefer to be upfront and honest about those things. As Patrik

Re: [akka-user] Spark Streaming using Kafka as a source and Akka with kafka ?

Use this: https://github.com/akka/reactive-kafka Also, please note that Spark and Akka are not really directly competing... Think about it this way: Can you build an HTTP server with Spark Streaming? Nope. Can you do that with Akka Streams? Yes. Does Akka Streams have built in machine learning

Re: [akka-user] Akka Streams + TCP + TLS

.lang.ClassNotFoundException: >> scala.runtime.java8.JFunction1 >> at java.net.URLClassLoader.findClass(URLClassLoader.java:381) >> at java.lang.ClassLoader.loadClass(ClassLoader.java:424) >> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) >> at ja

Re: [akka-user] Disable hostname verification

Read the docs: http://doc.akka.io/docs/akka/current/scala/http/client-side/https-support.html#Hostname_verification You should also force the SSL Config library to be 0.2.2 -- Konrad `ktoso` Malawski

Re: [akka-user] Akka Streams + TCP + TLS

(did the conversion in a rush) -- Konrad `ktoso` Malawski Akka @ Lightbend On 13 March 2017 at 22:26:51, Pablo Milanese (pablomilanes...@gmail.com) wrote:

Re: [akka-user] Akka Streams + TCP + TLS

I started it for scala here https://github.com/typesafehub/activator-akka-stream-scala However I made some mistake somewhere - would be awesome if you could help me notice where the mistake was :/ -- Konrad `ktoso` Malawski Akka

Re: [akka-user] Akka Streams + TCP + TLS

Here's a full example which does just that: https://github.com/typesafehub/activator-akka-stream-java8/blob/master/src/main/java/sample/stream/TcpTLSEcho.java Happy hakking On Mar 11, 2017 10:43 AM, "Pablo Milanese" wrote: > Hello !. > > I am actually looking for an

Re: [akka-user] Run akka-bench-jmh benchmarks

Please read the plugins docs: https://github.com/ktoso/sbt-jmh > jmh:run :-) -- Konrad `ktoso` Malawski Akka @ Lightbend On 9 March 2017 at 22:52:44, AbhijitPratap Singh ( singhabhijitpra...@gmail.com) wrote: I was intending to run the jmh benchmarks

Re: [akka-user] AKKA crashed using kryo serialization sometimes

Really? I was thing serialization would be needed for inter process communication. If you're in the same JVM then it's only inter-thread communication, so we don't serialize (unless you force that via config setting) Thanks, looking forward to a reproducer - most likely best to ping the kryo

Re: [akka-user] Re: Persistent FSM and at least once delivery

Thanks for the ticket, let us know if you have a moment to try it out :) -- Konrad `ktoso` Malawski Akka @ Lightbend On 5 March 2017 at 22:27:15, Tomer Rothschild (roto...@cloudshare.com) wrote: Thanks for the quick reply :) I have created the following

Re: [akka-user] Persistent FSM and at least once delivery

I'm considering using Akka for my team's next big project in Java. Very cool, thanks for reaching out too. I find both of the following capabilities to be desirable in the same actor: 1. Persistent FSM 2. At least once delivery I haven't found a Java abstract actor class that provides

Re: [akka-user] [Akka 2.4.3] - Cannot marshal Source[A,NotUsed] in presence of a ToResponseMarshaller[A]

Thanks for your patience and posting the reproducer, makes it much easier to find what's wrong :) There is one small typo basically, you need to provide a *ToEntityMarshaller* and not a To*Response*Marshaller. Think of it this way, you should provide the "most basic" marshaller and then the more

Re: [akka-user] AKKA crashed using kryo serialization sometimes

The reason it does not blow up locally is because then you don't hit the serialiser :) On Fri, Mar 3, 2017 at 9:26 AM, Konrad Malawski < konrad.malaw...@typesafe.com> wrote: > This sounds like it would be better reported at https://github.com/romix/ > akka-kryo-serializ

  1   2   3   4   5   6   7   8   9   10   >