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` M

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

with 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. > > SSLConfi

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

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 RawHeader it will at

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

way 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

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

ting 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] 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 don

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 ht

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 documen

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, vishal.ve...@exadatum.com

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 (tj5...

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 fetchi

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] 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 ti

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] 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

[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 mak

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 (

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 informa

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: https://stackoverflow.com/questions/44366796/no-matching-constructor-found-on-cl

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] akka-streams: what causes the downstream to be "cancelled"/onDownstreamFinish called?

With and my handler could > return a failed future, could that cause the downstream to cancel? > > Also not sure if it makes a difference, but I do have a throttler before > the mapAsync call: > .throttle(elements = 1, per = 2, maximumBurst = 1, ThrottleMode.shaping) > > Than

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 spinning

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

; .foldMap(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 ;-)

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 < konrad.mal

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 FSM, Persistence and multiple instances

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 p

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 yo

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

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 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 > plugin via TCK test maven d

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] 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] 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 route

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] 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 cancellab

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 resilien

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] 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 my tests pa

Re: [akka-user] Synchronising responses sent from parents and children

Hi Lawrence, In general, exactly one entity in a distributed system should be responsible for deciding about success / failure, otherwise there always will be a race of some kind. In your case though, the problem arrises because the service actor does not know if the transaction actor has complete

Re: [akka-user] Concept for the pressure queue

Hello again, replies in-line: [-- cut --] > In Pull based approach, if producer is creating more work, we can implement > a logic to add more worker actors to the system. These additional workers > will take the surge of work created by fast producer. This maintain's > balance or capability in the

Re: [akka-user] Re: Multiple Futures inside Actor's receive

Hello Soumya, how about maping over the Futures in a for comprehention, like this, and then sending the result back to the actor so it can set the value (*don't* modify a var from a Future (not safe – as it's executing on a different thread, and Actor guarantees don't hold any longer)). case SetSt

Re: [akka-user] Synchronising responses sent from parents and children

ode?: > > override def preRestart(exception) > client ! exception > context stop self > > On Thursday, August 7, 2014 12:29:05 PM UTC+1, Konrad Malawski wrote: > >> Hi Lawrence, >> In general, exactly one entity in a distributed system should be >> res

Re: [akka-user] Deploying Akka Cluster App To Amazon EC2 and Monitoring

> > [*Prakhyat*] The query is not specific to Amazon. I want to understand >> how deployment of akka cluster in amazon ec2 is different from deploying >> locally. Do configurations,setup or any other parameters change while >> running cluster in amazon? I did not get any such points shared over net

Re: [akka-user] Database actor design

Please refer to the docs about "Actor Systems - Blocking needs careful management", it answers your questions. You can also search this mailing list for "blocking operations in actors", this has been discussed a lot. Hope this helps! -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe

Re: [akka-user] Java with Lambda currying factory props method

Hello Hannes, This looks more or less how Java code will end up looking if you try to use functions all over the place. I think in your example you're overdoing the number of wrapped functions a bit, though there may be cases when this is needed I guess. Since you're now able to use MethodHandles

Re: [akka-user] Synchronising responses sent from parents and children

the success message had already been > sent. > > What are your thoughts? > > (p.s. I know that running with the 'incompetent developer' assumption > means they could quite-equally cock-up the fault handling code - but > providing they didn't, it would mean all other

Re: [akka-user] Synchronising responses sent from parents and children

hout giving away > implementation detail. > > > On Friday, August 8, 2014 1:18:52 PM UTC+1, Konrad Malawski wrote: > >> That also works, yes. >> I was unsure if sending the client your failure was OK for you. >> >> On 8 August 2014 at 14:16:34, Lawrence Wage

Re: [akka-user] What is akka message network overhead?

t;> >> On 08/06/14 08:46, Sean Zhong wrote: >> >> Konrad, thanks. >> >> After enabling the debug flag, >> >> I saw the system message like Terminate are using javaSerialiaer, is >> this expected? >> >> [DEBUG] [08/06/2014 22:19:11

Re: [akka-user] Connecting DistributedPubSubMediators between different ActorSystems

get the ClusterSingletons happy for Application A, B, > C, D > > Does this seem like a good plan? > :) > > > Thanks! > Brian - > > > On Thursday, August 7, 2014 1:48:55 AM UTC-5, Konrad Malawski wrote: > >> Hi Brian, >> No, PubSub works within a cluster –

Re: [akka-user] Connecting DistributedPubSubMediators between different ActorSystems

Oh, and I'd add roles to these nodes – so A nodes actually know they are "app-a" nodes (when starting up actors remotely etc). On Fri, Aug 8, 2014 at 3:27 PM, Konrad Malawski wrote: > Hello Brian, > yeah this sounds OK to me. > You may want to tweak when the clus

Re: [akka-user] Re: Akka Remoting fails for large messages

Hello Syed, So the reason we wanted to verify 2.3.4 is that we have implemented a separate way to propagate heartbeats in that version – shouldn't disconnect nodes under load from the cluster as easily. The topic here discussed has been touched upon a few times in the last weeks, refer to: arbitra

Re: [akka-user] Event Sourcing Single Writers

There is no "global transaction scope" – you're in a lock-less asynchronous distributed system, can't beat the CAP . I highly recommend watching this talk by Eric Evans about "Acknowledging CAP at the Root - in the Domain Model

Re: [akka-user] Deploying Akka Cluster App To Amazon EC2 and Monitoring

> > Thanks. Conversation with you helped again. > Very glad to hear that, thanks! > I got most of the answers. Will go through articles shared by you. > But still have many open questions on akka cluster working in Amazon. > 1. Understand how deployment of akka cluster in amazon ec2 is different

Re: [akka-user] AkkaPersistence in Cluster

Hello Martin, Yes, there needs to be exactly one actor which performs writes for a given persistenceId in the system (though using *ClusterSharding* you can easily migrate it between servers etc). Other "read actors" should be Persi

Re: [akka-user] sbt dist with version 2.3.2

capability as akka-sbt-plugin but using > sbt-native-packager. > > > On Sunday, August 17, 2014 6:08:12 AM UTC-7, Konrad Malawski wrote: >> >> Hi guys, >> Have you seen the http://www.scala-sbt.org/sbt-native-packager/index.html sbt >> plugin? >> The sbt

Re: [akka-user] controlling the persisted actor lifecycle

Hello Barak, Killing an Actor will “remove it from memory” (make it eligable for GC), same rule holds for Persistent Actors. To kill it and keep the persistent state just send a PoisonPill or an application level message that will ask the actor to context stop self. If you want to discard the same

Re: [akka-user] Event Version in Akka Persistence

You may also want to check out this thread on akka-user Best practices using Akka Persistence with long-running projects where we discussed this in detail. On Thu, Aug 28, 2014 a

Re: [akka-user] Migrating data and stability with akka-persistence

Hello Mario, Thanks for your interest! We are currently evaluating persistence options for our backend. We are > looking at akka-persistence but we have a couple of concerns: > > 1. How stable is the API now? Is it close enough to "final" that we could > depend on it and not having to make code ch

Re: [akka-user] in-memory

Hi! Yes. :-) -- Konrad 'ktoso' Malawski On 3 Sep 2014 16:21, "ffif" wrote: > Hi everybody > I am new in akka and have two question. If akka supports in memory process? > Thanks > > -- > >> Read the docs: http://akka.io/docs/ > >> Check the FAQ: > http://doc.akka.io/docs/akka/cu

Re: [akka-user] exactly *one* persistence actor with the same persistenceId active ?

Hello guys, wherever you need strict order in a distributed system there must be one source of sequence-truth, in akka-persistence's case this means having one persistent actor, otherwise they'd compete with each other and "behaviour is undefined" yet surely undesired they could overwrite events or

Re: [akka-user] exactly *one* persistence actor with the same persistenceId active ?

a video from the Akka Persistence ScalaDays 2014 talk <http://parleys.com/play/53a7d2c3e4b0543940d9e53b/chapter0/about> we did, in which Patrik explains why Cluster Sharding is so useful with Persistent Actors. Hope this helps! On Mon, Sep 8, 2014 at 8:48 AM, Konrad Malawski wrote: > H

Re: [akka-user] Routing to subset of children

Hi guys, exactly, I'd go with an Subchannel classification EventBus in this case. This way you can even define hierarchies of these topics the actors are interested in. You may also enjoy this article by Ben Howell which we've featured on letitcrash.com

Re: [akka-user] When to use Patterns.ask

Hint: tell is cheaper. (-: ​ On Mon, Sep 8, 2014 at 2:50 PM, Chanan Braunstein < chanan.braunst...@pearson.com> wrote: > Usually, we try to only do an ask from the play controller into the actor > system, everything past that we do with tells. > > Although, we haven't branched out yet to remote/

Re: [akka-user] Akka Persistence - issue with Recovery

Hello Moiz, That's weird (and could be a bug?). Would you mind collecting some logs with debug logging enabled? Here's how to enable it: http://doc.akka.io/docs/akka/snapshot/java/logging.html#auxiliary-logging-options Also, logging deadletters may be useful 1. akka { 2. log-dead-letters =

Re: [akka-user] Cluster aware routers with routees that needs some time to be initialized

Hi guys, I've updated the docs (and resolved this issue). It should now be clearer to users what to expect from the group router: https://github.com/akka/akka/issues/15241 Cheers! On Mon, Sep 8, 2014 at 9:09 AM, Martynas Mickevičius < martynas.mickevic...@typesafe.com> wrote: > I think the docum

Re: [akka-user] Re: Issue with call of scheduler.schedule in actor system without actors.

Hi Ruslan! Sorry for the late reply, I see you already found the problem. Yes, the call-by-name can be confusing (you're not the first who has been surprised by it). I think it's fair to say we should somehow document it more explicitly (maybe just CAPS written warning in the scaladoc would do..).

Re: [akka-user] Manifest Event Sourcing Application's Performance

For end-to-end tests I have used and liked http://gatling.io a bit. For microbenchmarks (not what you need for your case IMO), I'd recommend JMH http://openjdk.java.net/projects/code-tools/jmh/ and the sbt plugin: https://github.com/ktoso/sbt-jmh Happy hakking On Wed, Sep 10, 2014 at 9:53 AM, Pra

Re: [akka-user] Event sourcing and external service integration

Hi Iain! I skimmed over it and I think you've ported it nicely! Esp. using AtLeastOnceDelivery fits very well. This could be very useful for others so I think I'll post this to letitcrash.com :-) On Tue, Sep 9, 2014 at 11:51 PM, Iain Hull wrote: > As part of learning how to apply akka-persisten

Re: [akka-user] Re: Implementation of fire and forget kind of webservice

Also, spray-client is when you need http communication. If the only thing you’re after here is fire-and-forget semantics all you need is ! (tell), that’s exactly the semantics it has. Futures are not "and forget", because you do get some information in them (completed / failed). ​ On Fri, Sep 12,

[akka-user] [RELEASE] Akka Streams & Http 0.7 released!

Dear hakkers, today we are very excited to share with you another early preview milestone of Akka Streams and Akka HTTP. Version 0.6 was not widely announced because we were preparing some major work on the API and most of that is now finished. Behold, the new FlowGraph DSL (we have implemented Sc

Re: [akka-user] Rest api architecture design questions with clustering

Hello Ignacio! I'll try to address your questions, but some seem to need deeper architecture review etc, that is something we could do but probably as an commercial offering - if that's something you're interested please contact me / sales directly (made quite a few people very happy this way :-)).

Re: [akka-user] LevelDB dependency

This may be a good idea and is worth discussing when we move towards 2.4. It's worth opening an issue about this so we at least discuss it during planing of the next persistence sprint, would you mind doing that? Thanks! On Fri, Sep 12, 2014 at 12:45 PM, ahjohannessen wrote: > Hi, > > Would it n

Re: [akka-user] Using Scheduler vs deadline to mimic some backend: scheduler is slow(er)

Hi Alex! Let me dig into the difference between a Scheduler and a Deadline right away: def quit(m: SimpleMsg) = { // ... val deadLine = delay milliseconds fromNow*while (deadLine.hasTimeLeft()) { // A.K.A. *"hog the thread" :-) // do some work... } val stopActor = cont

Re: [akka-user] Akka Actors In Scala Vs Akka Actors In Java:Event Sourcing

Hi Prakhyat, "It depends". We provide APIs for everything in both Java and Scala. Is it better to create actor system or actors in scala or java? > There is no "better" as it depends on your team, their skills and willingness to learn. I do think it's worth to get over the initial learning curve

Re: [akka-user] Akka Actors In Scala Vs Akka Actors In Java:Event Sourcing

Language choice should have marginal (collection conversions will happen for example) has marginal impact on performance here. If you really care you should benchmark things :-) -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- >> Read the docs: http:/

Re: [akka-user] akka dispatcher "memorize" the last round connections?

Hi Liang, It's most probably known problems with early releases of 2.3 like Patrik mentioned. There's no cache-files involved, all runtime stuff only – I'd highly recommend upgrading to the latest Akka version (or higher than 2.3.4 at least). On Sun, Sep 14, 2014 at 2:35 AM, Liang Gong wrote: >

Re: [akka-user] LevelDB dependency

Thanks. -- Konrad 'ktoso' Malawski On 14 Sep 2014 15:09, "ahjohannessen" wrote: > Opened an issue, https://github.com/akka/akka/issues/15884 > > On Saturday, September 13, 2014 1:16:14 PM UTC+1, Konrad Malawski wrote: >> >> This may be a good idea and

Re: [akka-user] Restarting Actor System in JBoss application server

You need to awaitTermination. Shutdown is not blocking and only signals that to the actor system that it should start shutting down -- Konrad 'ktoso' Malawski On 16 Sep 2014 12:56, wrote: > Hi All, > > We are running our akka (2.10-2.2.1) actor system inside JBoss EAP 6.1. > > In one of the flo

Re: [akka-user] foreach in akka-streams 0.7

Hello Adam, yes, there is: .withSink(ForeachSink(el => ).run() ​ The sink also holds a future which you can watch for completion, see: http://doc.akka.io/api/akka-stream-and-http-experimental/0.7/?_ga=1.32419708.350209094.1396869304#akka.stream.scaladsl2.ForeachSink Hope this helps! -- Cheers, K

Re: [akka-user] Electing new cluster singleton on clean shutdown

Hi Krzysiek! The singleton should indeed be migrated to another node if it's current node dies automatically. What do you see in the logs (about cluster membership, and/or the singleton)? Do you have any role requirements on where the singleton can be running? On Thu, Oct 9, 2014 at 1:32 PM, Krzy

Re: [akka-user] source code for akka-stream

Hello David! Akka streams live currently on the `release-2.3-dev` branch: https://github.com/akka/akka/tree/release-2.3-dev And of course each release has a git tag associated with it, for example 0.8 is here: https://github.com/akka/akka/tree/akka-stream-and-http-experimental-0.8 Please note that

Re: [akka-user] Re: [2.3.2] Akka actor not found through ActorSelection

Hi guys, sorry we didn't reply in this thread (seems we missed it somehow). In general the code as shown should be working fine in any Akka version... Raymond's hint that using a "plain actor system" works may hint at some configuration differences with respect to "play's actor system", hm. Could

Re: [akka-user] Akka HTTP 0.8 - routing

Hello George, While we can't give "hard dates", we do estimate http to be ready within a month or so (as Roland mentioned recently here https://groups.google.com/forum/#!topic/akka-user/3JYHqg2nO6Y ). We're focused 100% on akka-streams and http during these months, trying to get it out there ASAP :

Re: [akka-user] Re: Akka Actors & extrernal Worker threads

Agreed with Rafal, One tip here is that you can provide such dispatcher to a Future by: implicit val dispatcher = system.dispatchers.lookup("blocking") Future { } ​ With having configured such a blocking dispatcher in application.conf -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe

Re: [akka-user] Akka streams newbie questions

Sure, there's a lot of tests in our repo. This one contains a lot of complicated graphs: https://github.com/akka/akka/blob/release-2.3-dev/akka-stream-tests/src/test/scala/akka/stream/scaladsl2/FlowGraphCompileSpec.scala And in general loads of tests in this directory: https://github.com/akka/akka/

Re: [akka-user] Akka streams newbie questions

It's https://github.com/akka/akka/blob/release-2.3-dev/akka-stream-testkit/src/test/scala/akka/stream/testkit/AkkaSpec.scala It's in src/test so it's not part of any artifact, you could copy paste it if you want to play around though.. It's not the akkaspec / testkit we want users of akka-streams

[akka-user] Re: How to understand "completely fair locks do not exist on the JVM"

Hi Nan, please try to avoid double-posting threads between akka-user and akka-dev. This question has ben answered on akka-dev: https://groups.google.com/forum/#!topic/akka-dev/bxSBxwHKw6M -- Konrad W dniu środa, 15 października 2014 04:10:56 UTC+2 użytkownik Nan Zhu napisał: > > Hi, all > > Whe

Re: [akka-user] Akka Logging - Best practises

Hi Nils, I actually would keep logging separated as you have now, and simply use slf4j as provider for both so it will be one config file ( http://doc.akka.io/docs/akka/snapshot/java/logging.html#slf4j ). In your non actor classes you'd use the scala-logging

Re: [akka-user] AtLeastOnceDelivery and crash on recovery

Hi Jeroen, Thanks for preparing the example, it made checking what the problem is very simple :-) Try searching for `confirmDelivery` in your code snippet. It's not there. And with no confirmation, there is no information on in the sending-actor that the target has really received the message. Th

Re: [akka-user] ClusterSharding: question about shard recovery

Hi Vadim, I'm not exactly sure what you mean by "on other nodes with the same role". How did you setup cluster sharding? When do you expect the shard to be brought back? I'll happily help but seem to be missing context here a bit. On Wed, Oct 15, 2014 at 4:52 PM, Vadim Bondarev wrote: > Hi all,

Re: [akka-user] Akka Persistence Journal Access

Hello there Richard, while it’s very low level API, it is publicly accessible if you want to talk to it. Access it like this: val journalActor: ActorRef = Persistence(system).journalFor("persistence-id-something") In theory this is ready to support multiple journals in the same actor system, alth

Re: [akka-user] Akka Logging - Best practises

ala-logging for me? > What does it provide extra than using slf4j directly? > > Nils-H > > On Friday, October 17, 2014 2:13:22 PM UTC+2, Konrad Malawski wrote: >> >> Hi Nils, >> I actually would keep logging separated as you have now, and simply use >> slf4j as

Re: [akka-user] Akka Persistence Journal Access

" api for a specific persistent > actor, I assume I could create a "per-request" view just for that one actor > and customize the replay settings? > > Like everyone else, I am anxiously awaiting the new streams-based stuff :) > > On Fri, Oct 17, 2014 at 3:45 PM, Ko

Re: [akka-user] Why aren't views supposed to read persistent actor's snapshots?

That is an interesting use case, glad it works out for you! Happy hakking! On Thu, Oct 16, 2014 at 10:35 AM, Krzysztof Ciesielski < panciesiel...@gmail.com> wrote: > Hi, > > Thanks for detailed answer. The case that you are mentioning requires a > single view, possibly a cluster-singleton in case

Re: [akka-user] Best way to resend MemberUp

Hi Miguel! Sorry I had you waiting on this one for so long, let’s dive into the cluster’s depths right away then! In your case you would need make the seed node join the previous node. If you really want to do this, there’s programatic API to do this (Cluster(system).join theOtherGuy), but I assum

Re: [akka-user] Custom dispatcher seems to be available but not being used for actor

Hi lakshmi! You have properly found the reason why this is so: > The other weird thing I noticed is that if I cut short the application.conf without the "deployment" section, then it does actually use the db-dispatcher. Wonder why? Configuration for dispatchers (in general the entire "Deploy" sect

Re: [akka-user] ClusterSharding: question about shard recovery

> 2 Result state: | B-1 - 10 | B-2 - 20 + ProcessCoordinator | : total >> 30 >> >> >> 3 Action: Up B-3 Kill B-2 >> 3 Result state: | B-1 - 10 + ProcessCoordinator | B-3 - 0| : total 10 >> Progress impossible >> >> This is where I stuck >&

Re: [akka-user] Akka pipelines and SEDA

By a very brief scan of that website, it would seem you may be interested in reactive-streams and Akka-streams. While not yet, we can certainly imagine having such an adaptive execution with streams. http://www.reactive-streams.org http://akka.io/news/2014/09/12/akka-streams-0.7-released.html --

Re: [akka-user] Any way possible to integrate with Arduino?

I have not seen Akka running on an Arduino, but talking to an Arduino could be totally doable if you implement a http server on it. That'd be the preferred method of talking to it I'd imagine. On the other hand it's perfectly reasonable to have a JVM and Akka running on a Raspberry Pi (it's a bit

Re: [akka-user] Accessing Future's onComplete Internal variables

Hi Syd, your code samples are not valid Java (well, the first one could be if testVar would be a field, but that's unsafe instead maybe use `AtomicReference` and `set` it from the completion?). OnComplete has a `void` method so you cannot return from it. Instead of taking things out of the future

Re: [akka-user] Accessing Future's onComplete Internal variables

to use it. Cheers > > Syd > > > > > On Monday, 17 November 2014 12:10:16 UTC+1, Konrad Malawski wrote: >> >> Hi Syd, >> your code samples are not valid Java (well, the first one could be if >> testVar would be a field, but that's unsafe instead mayb

  1   2   3   4   5   6   7   8   9   10   >