[akka-user] Re: Wikipedia presence

Created an https://en.wikipedia.org/wiki/Reactive_Streams article. On Wednesday, December 26, 2012 at 12:42:15 AM UTC+2, Nicholas Sterling wrote: > > After reading about Akka's dataflow concurrency, I looked it up on > Wikipedia. I noticed that there were links at the bottom to various > dataf

Re: [akka-user] Migrating to akka stream 2.0.1, tests throw assertion error "`remaining` may not be called outside of `within`"

Hi, akka stream TestKit v1.0 does the following on line 221: /** * Expect and return a data element. */ def expectNext(): I = probe.expectMsgType[OnNext[I]].element And akka stream TestKit v2.0.(1) does the following on line 253: /** * Expect and return a stream element. */ def expectNext

Re: [akka-user] Migrating to akka stream 2.0.1, tests throw assertion error "`remaining` may not be called outside of `within`"

Hi, Correct, I upgraded the plugin from 1.0 to 2.0.1 in one go. I changed the version to 2.0 and it does the same thing. The stacktrace is: [info] InMemoryReadJournalTest: [info] ReadJournal [info] - should support currentPersistenceIds *** FAILED *** [info] java.lang.AssertionError: `remainin

Re: [akka-user] Migrating to akka stream 2.0.1, tests throw assertion error "`remaining` may not be called outside of `within`"

This sounds a bit weird... I don't think those changed that much in the move to 2.0. Could you make the problem example a gist (gist.github.com or complete snippet in email, ready to copy/paste) I could downlaod and quickly have a look? Thanks in advance! --  Cheers, Konrad 'ktoso’ Malawski Akk

Re: [akka-user] Microservice architecture with akka

Hi ash.ta, Akka is not only about Actors, but about Actors and Messages, as the Actors communicate each other only by exchange of Messages. In an Akka Cluster, because of the Location Transparency, the Actors can collaborate each other without the need to be aware of were the other Actor is runnin

[akka-user] Migrating to akka stream 2.0.1, tests throw assertion error "`remaining` may not be called outside of `within`"

Hi, I have a question about akka stream. I want to migrate a project from akka 2.3 to 2.4.1 and akka stream 1.0 to 2.0.1 and I must now refactor tests. In the test an akka stream is used with the fluent like DSL in which one can expect messages. , an assertion error will be thrown "`remaining

[akka-user] [ANNOUNCE] Akka Streams & HTTP 2.0.1 released!

Dear Hakkers, we—the Akka committers—are very pleased to bring to you a quick follow-up maintenance release to Akka Streams & HTTP 2.0 which was released earlier this week. This release primarily aims to resolve a bug we found s

Re: [akka-user] Microservice architecture with akka

cunicaommtion = communication. On Wednesday, December 23, 2015 at 9:46:04 PM UTC+2, ash.ta wrote: > > filippo, can you elaborate a bit more for a newbie like myself about the > pattern you are using for inter-services cunicaommtion? > let me explain you what i am talking about. > i clearly und

Re: [akka-user] Microservice architecture with akka

filippo, can you elaborate a bit more for a newbie like myself about the pattern you are using for inter-services cunicaommtion? let me explain you what i am talking about. i clearly understand the model of microservices built around a message bus. there you have a system of services incorporat

[akka-user] Grouped Message Queues

I'm trying to see if it might be possible to simulate this feature of JMS in Akka: https://docs.oracle.com/cd/E23943_01/web./e13727/uoo.htm#JMSPG390 Basically, I want to make a message queue that can have many producers and many consumers. I want my messages to have different "topics". M

[akka-user] Re: How to process HttpRequest's from multiple connections in one flow?

Hi! Is anyone from akka-http team was able to look into the problem? Thanks, Dmitry Ustimov -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://gr

Re: [akka-user] Akka PersistenceQuery java example

Hi Jan, please read about Akka Persistence. >From your code snippet it's not possible to say if the events are persisted under the persistenceId "persistentActor-4-java" or not. What's the def persistenceId in the Actor look like? What is not working in the example you pasted? -- Konrad On Wed,

[akka-user] Akka PersistenceQuery java example

Hi, Now I have gone through Persistence Query , akka-sample and akka-doc

Re: [akka-user] Fusing in akka-streams 2.0

On Tuesday, December 22, 2015 at 8:37:08 PM UTC+1, Adam Warski wrote: > > Having conflate only makes sense if there's some non-fused component out > there I guess, but you are correct of course that it can be fused with > things before/after it. > I thought a bit about this. Actually, it is not

Re: [akka-user] Microservice architecture with akka

Hi Yaakov, I will not take this statement "microservices should communicate with each other using language agnostics API like REST" as a dogma written on stone. I am developing a microservice architecture using Akka-cluster, so that each microservice join the same cluster. Then I have some actor th

Re: [akka-user] [akka-stream] Wait until two sinks are completed

You need the s1 and s2 values to "contribute to the materialized value of graph". Please read this section of the docs:  http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0/java/stream-composition.html then:  http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0/java/stream-graph

Re: [akka-user] Fusing in akka-streams 2.0

Thanks for the heads up, Konrad! Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > On 23 Dec 2015, at 09:38, Konrad Malawski > wrote: > > FYI, R

Re: [akka-user] Fusing in akka-streams 2.0

Ah, damn, yes, I forgot the ping :-( > 23 dec 2015 kl. 09:38 skrev Konrad Malawski : > > FYI, Roland's docs update merged: https://github.com/akka/akka/pull/19268 > > I'll release 2.0.1 today as we found a bug in InputStreamPublisher. > > -- > Cheers,

Re: [akka-user] Fusing in akka-streams 2.0

FYI, Roland's docs update merged: https://github.com/akka/akka/pull/19268 I'll release 2.0.1 today as we found a bug in InputStreamPublisher. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 23 December 2015 at 09:14:58, Adam Warski (a...@warski.org) wrote: :-) But you are right, even th

Re: [akka-user] Fusing in akka-streams 2.0

> :-) > > But you are right, even though “semantics” didn’t change—for some suitable > definition—user expectations may still be violated. I’ll write up some docs > right away, it would be great if you could review them—I’ll ping you > (@adamw, right?). > Sure :) @adamw is the right handle >