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

Hi, Is there any way to set different priorities on different inlets in MergePreferred if it has more that two inlets? Thanks! Regards, Sergey -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] How to stop unstoppable actor?

rigger it from the > postStop of the actor. > Read about those concepts in the docs. > > -- > Konrad Malawski > > On 24 January 2017 at 20:02:40, Sergey Sopin (sopi...@gmail.com > ) wrote: > >> Hi, >> >> I am trying to solve problem with the actor whic

[akka-user] How to stop unstoppable actor?

Hi, I am trying to solve problem with the actor which works too long. In my case "heavy" actor runs akka-stream which calculates some values, sometimes this calculation takes too much time and I want to stop it. I supposed that it will be stopped automatically in case parent actor throw

Re: [akka-user] Re: [Akka-streams] Cannot push port twice

2c81435adef3fe7 > > cheers, > Rafał > > W dniu środa, 11 stycznia 2017 20:26:24 UTC+1 użytkownik Sergey Sopin > napisał: >> >> Hi again, >> >> Rafał, could you please give me an example of how to implement waiting? >> >> Thanks! >> >> -

Re: [akka-user] Re: [Akka-streams] Cannot push port twice

Rafał > > W dniu wtorek, 10 stycznia 2017 19:07:48 UTC+1 użytkownik Sergey Sopin > napisał: >> >> So, does it make sense? It seems it would be better to allow inlet be >> pullet once per outlet, not once at all. >> May be there is some existing solution for the pr

Re: [akka-user] Re: [Akka-streams] Cannot push port twice

orek, 10 stycznia 2017 19:07:48 UTC+1 użytkownik Sergey Sopin > napisał: >> >> So, does it make sense? It seems it would be better to allow inlet be >> pullet once per outlet, not once at all. >> May be there is some existing solution for the problem above? >> >

Re: [akka-user] Re: [Akka-streams] Cannot push port twice

decision and push it to > the appropriate outlet > 3. Goto 1 > > This way you only ever pull inlet once, and once the element is available > you can always push it out, since both outlets are available. > > Cheers, > Rafał > > W dniu wtorek, 10 stycznia 2017 19:07:48 UTC+1 uż

Re: [akka-user] Re: [Akka-streams] Cannot push port twice

So, does it make sense? It seems it would be better to allow inlet be pullet once per outlet, not once at all. May be there is some existing solution for the problem above? - Sergey понедельник, 9 января 2017 г., 17:03:43 UTC+2 пользователь Sergey Sopin написал: > > Hi Endre, &g

Re: [akka-user] Re: [Akka-streams] Cannot push port twice

ou see something wrong there. Thanks! Regards, Sergey понедельник, 9 января 2017 г., 16:10:14 UTC+2 пользователь drewhk написал: > > > > On Mon, Jan 9, 2017 at 3:03 PM, Sergey Sopin <sopi...@gmail.com > > wrote: > >> Hi again, >> >> In my case I have 1 i

[akka-user] Re: [Akka-streams] Cannot push port twice

ly. > > Julian > > > On Monday, January 9, 2017 at 12:46:43 PM UTC, Sergey Sopin wrote: >> >> Hi, >> >> I have created FanOutShape2 shape with cusom logic: >> >> @Override >> public GraphStageLogic cre

[akka-user] Re: [Akka-streams] Cannot push port twice

On Monday, January 9, 2017 at 12:46:43 PM UTC, Sergey Sopin wrote: >> >> Hi, >> >> I have created FanOutShape2 shape with cusom logic: >> >> @Override >> public GraphStageLogic createLogic(Attributes inheritedAttributes) { >>

[akka-user] [Akka-streams] Cannot push port twice

Hi, I have created FanOutShape2 shape with cusom logic: @Override public GraphStageLogic createLogic(Attributes inheritedAttributes) { return new GraphStageLogic(shape) { { setHandler(in, new AbstractInHandler() { @Override

Re: [akka-user] Akka stream never completes

Yep, thanks a lot! I completely forgot about it. вторник, 27 декабря 2016 г., 19:53:45 UTC+2 пользователь √ написал: > > eagerClose on the Merge? > > -- > Cheers, > √ > > On Dec 27, 2016 6:30 PM, "Sergey Sopin" <sopi...@gmail.com > > wrote: > &

[akka-user] Akka stream never completes

Hi all, I am trying to build a flow, which will return CompletionStage with the List inside. It looks like following: private CompletionStage buildAndRunGraph(ArrayList sourceList) { Source source = Source.from(sourceList); Materializer materializer =

[akka-user] [akka-streams] Implementing custom graph stage logic for FanOut shapes

Hi, I am trying to implement custom logic for UniformFanOutShape, but it seems I do something wrong. public class SPMessageSplitter extends GraphStage> { //Inlet public final Inlet in = Inlet.create("Inlet.in"); //Outlets public

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

tp%3A%2F%2Fblog.akka.io%2Fintegrations%2F2016%2F08%2F25%2Fsimple-sink-source-with-graphstage=D=1=AFQjCNHYHicBY3_8IE0RSR6Cy7dhz3Geog> > > W dniu poniedziałek, 24 października 2016 23:38:54 UTC+2 użytkownik Sergey > Sopin napisał: >> >> Hi Rafał, >> >> - sink requests data from you >

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

Hi Rafał, - sink requests data from you > - OutletHandler.onPull is invoked on the outlet where the sink is > connected to > - you propagate demand outstream by calling pull on any (or all) of your > Inlets, depending on your logic > - eventually data becomes available upstream > -

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

Rafał, - If I understand onPulI() function correctly, it is allowed only for outlets, so in order to pull something you need to push it in this outlet firstly. - Balancer has been taken from the docs: Balancing_jobs_to_a_fixed_pool_of_workers

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

Hi Rafał, Code that uses my shape is following: private CompletionStage buildAndRunGraph(ArrayList sourceList) { //First function Source source = Source.from(sourceList); Materializer materializer = ActorMaterializer.create(context());

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

see FlowShape etc for examples how to do this. > > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 19 October 2016 at 08:03:16, Sergey Sopin (sopi...@gmail.com > ) wrote: > > Hi, > > Yes, but it seems that I

[akka-user] Re: [akka-stream] Problems with the shape creation

ziernika 2016 22:12:07 UTC+2 użytkownik Sergey Sopin > napisał: >> >> Hi again, >> >> I have a very specific case. My flow looks like this one: >> >> >> <https://lh3.googleusercontent.com/-qrP4yHkVYI8/WAaAO1-q67I/Abw/acUT-YaG48k0lo7MkePGv9QVV

[akka-user] Re: [akka-stream] Problems with the shape creation

om the hip here, apologies if it does > not compile straight away) into your graph? That could help you locate > where the messages are stuck / discarded. > > Cheers, > Rafał > > W dniu poniedziałek, 17 października 2016 20:22:43 UTC+2 użytkownik Sergey > Sopin napi

[akka-user] Re: [akka-stream] Problems with the shape creation

Sink.foreach(_ > => println("beep!"))) (shooting from the hip here, apologies if it does > not compile straight away) into your graph? That could help you locate > where the messages are stuck / discarded. > > Cheers, > Rafał > > W dniu poniedziałek, 17 paździ

[akka-user] Re: [akka-stream] Problems with the shape creation

People say that following article may help: http://degoes.net/articles/insufficiently-polymorphic However, I still don't understand what's wrong with it. Any help will be appreciated. Thanks! Regards, Sergey -- >> Read the docs: http://akka.io/docs/ >> Check the

[akka-user] [akka-stream] Problems with the shape creation

Hi, I am trying to create my own akka streams shape with several Inlets and Outlets. I have written following code: package kernel.modeller.workers.streamFinder.generic import akka.stream.{Shape, Outlet, Inlet} import scala.annotation.unchecked.uncheckedVariance import

Re: [akka-user] Re: [akka-streams] Debug of custom stream processing logic

Yep, thanks! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are

Re: [akka-user] Re: [akka-streams] Debug of custom stream processing logic

It may work, however it will not give me full picture of what is going on. Thanks. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives:

Re: [akka-user] Re: [akka-streams] Debug of custom stream processing logic

I agree, but I need to understand that this logic is being called. I do not need to debug whole flow, I need only one function inside one shape. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: [akka-streams] Debug of custom stream processing logic

Hi, The question is still valid :) Thanks. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You received

[akka-user] [akka-streams] AbstractOutHandler in the shape with several Inlets

Hi, I am trying to define custom logic for the shape with several inlets (for example custom shape with 2 or more inlets). I was trying to avoid defining out handler for the Outlet, however it throws an error, so I suppose that there is no default behaviour in the shape class. The problem is

[akka-user] Re: [akka-streams] I have problems with adding Filter to a graph

The problem was in a return type. I was trying to assign FlowShape to a UniformFanInShape. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives:

[akka-user] Re: [akka-streams] I have problems with adding Filter to a graph

Small addition. The error itself looks like this: [error] D:\Work\Development\Projects\Myzir\trunk\app\kernel\modeller\workers\streamFinder\generic\SubPathProcessingAbstractShape.java:36: inference variable S has incompatible bounds [error] equality constraints:

Re: [akka-user] [akka-streams] It is not possible to create Graph with the custom shapes

d then write the ports of > the resulting Shape using the normal GraphDSL methods. There is no need to > make the wiring aware of your special shape. > > Regards, Roland > > Sent from my iPhone > > On 19 Sep 2016, at 22:35, Sergey Sopin <sopi...@gmail.com > > wrote: >

[akka-user] [akka-streams] It is not possible to create Graph with the custom shapes

Hi, Due to performance reasons I decided to create my new custom Shape with several inlets and several outlets (5 in and 3 out in my case). Then I decided to create Graph with the new element and realized that it is not possible without rewriting Graph object. In order to create my own shape I

[akka-user] [akka-streams] I have problems with adding Filter to a graph

Hi, I am trying to create and add filer to a graph. This filter receives request and returns new object with another data type. I tried to do it like that: final UniformFanInShape A = builder.add(Flow.of(CoverRequest.class).map(mes -> new CoverSetterData(mes)));

Re: [akka-user] [akka-stream] Multi input/output flow

t; > Notice that it's still fully typesafe for users of the shape! > > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 25 August 2016 at 20:07:02, Sergey Sopin (sopi...@gmail.com > ) wrote: > > Thanks a lot for

Re: [akka-user] [akka-stream] Multi input/output flow

> > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 25 August 2016 at 15:55:14, Sergey Sopin (sopi...@gmail.com > ) wrote: > > Hi, > > I am trying to create multi input/output flow. It should obtain mes

[akka-user] [akka-stream] Multi input/output flow

Hi, I am trying to create multi input/output flow. It should obtain messages from different Inlets and emit to different Outlets based on parameter inside the message. Something like following: 1. ... A elem = grab(in1); 2.if (p.test(elem)) { 3.

Re: [akka-user] Akka Streams Graph Editor tool

i > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 22 August 2016 at 13:14:17, Sergey Sopin (sopi...@gmail.com > ) wrote: > > Hi again, > > Omnigraffle is very good program, but I use Windows :( > Can you recommend something for it? > &g

Re: [akka-user] Akka Streams Graph Editor tool

topia.com/stencils/1493 by Derek Wyatt > > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 16 July 2016 at 17:44:18, Sergey Sopin (sopi...@gmail.com ) > wrote: > > Hi, > > Is there any tool which allows to

[akka-user] Akka Streams Graph Editor tool

Hi, Is there any tool which allows to draw graphs as they were shown in akka docs? I mean that allows using the same blocks and elements. Thanks a lot! Best regards, Sergey -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Patterns.Ask replacement

cessing pipelines than "get one >> element"-request-response type of interaction. >> >> -- >> Johan >> >> On Tue, Jul 5, 2016 at 9:22 PM, Sergey Sopin <sopi...@gmail.com >> > wrote: >> >>> Hi, >>> >>> Is there any possi

[akka-user] Patterns.Ask replacement

Hi, Is there any possibility to replace akka.patterns.ask / pipe communication with akks-streams? I was looking for at least small example, but could not find it. I suppose that it can be done with BidiFlow, but I am not sure if I know how. I would be very grateful for such example. Thank

[akka-user] Bad example in documentation

Hi, It seems that one of examples in the documentation contains bug, namely: http://doc.akka.io/docs/akka/2.4.7/java/stream/stream-graphs.html 1. final Source in = Source.from(Arrays.asList(1, 2, 3, 4, 5)); 2. final Sink> sink = Sink.

Re: [akka-user] How to get parent of router from routee?

y used for supervision and creating "islands" >> that fail together etc. (read up on supervision hierarchies). >> >> Hope this helps. >> >> -- >> Cheers, >> Konrad 'ktoso’ Malawski >> <http://akka.io>Akka <http://akka.io> @ Lightbend <

[akka-user] How to get parent of router from routee?

Hi, Is it possible to get parent of router from routee? If I would use context().parent() it will return router itself, but I need to find parent of parent in this case. Thanks. Best regards, Sergey Sopin -- >>>>>>>>>> Read the docs: http://akka.io/docs/

[akka-user] Error while creating router from config

Hi, I am trying to create router from configuration but I'm getting ConfigurationException. My code is following: ActorRef subPathFinderRouter = context().actorOf(FromConfig.getInstance().props(Props.create(SubPathFinderActor.class)), "subPathFinderRouter"); Config:

Re: [akka-user] Re: Akka behaviour

Sep 22, 2015 at 7:07 PM, Sergey Sopin <sopi...@gmail.com > > wrote: > >> Hi Patrik, >> >> Thank you for clarification. >> I have been using onComplete() procedure in order to check response >> status, but now I have replaced it with the Future.map(). As

Re: [akka-user] Re: Akka behaviour

ipeTo and then you will > receive a akka.actor.Status.Failure message with the exception cause. Note > that this is a message, and you have to actively throw the cause to trigger > supervision action. > > Regards, > Patrik > > On Sat, Sep 12, 2015 at 10:32 PM,

[akka-user] Akka behaviour

Hi all, I have problems with Akka in case of errors, namely: Ask time out. I suppose that the system should stop processing and restart itself when error happens. I have supervisor actor with following supervision strategy: private static SupervisorStrategy strategy = new

[akka-user] Re: Akka behaviour

Workflow is following: -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

[akka-user] Re: Akka massages delivery and memory issue

It seems I have dead lock on my data, because I am passing the same object to several actors in parallel. воскресенье, 16 августа 2015 г., 12:03:43 UTC+3 пользователь Sergey Sopin написал: Hello, I have some problems with Akka and memory, hope you can help me. I have following code

[akka-user] Akka massages delivery and memory issue

Hello, I have some problems with Akka and memory, hope you can help me. I have following code: //CallerActor procedure private IterableFutureObject process(ConfiguredPathProcessingRequest request) { CollectionFutureObject result = new ArrayList();

Re: [akka-user] Message was not delivered issue

On Sun, May 3, 2015 at 12:48 PM, Sergey Sopin sopi...@gmail.com javascript: wrote: Hi, I'm developing a system based on Akka and I got stuck with situation which is completely unclear for me. I have three actors with following hierarchy: Root actor - SubPathProcessingSupervisor

Re: [akka-user] Message was not delivered issue

It seems my problem is solved. I have stopped root actor before messages were delivered to child ones. Sorry for disturbing and thank you. Regards, Sergey среда, 6 мая 2015 г., 13:30:12 UTC+3 пользователь Sergey Sopin написал: Hi Endre, I tried to reproduce my problem, but I could not do

[akka-user] Message was not delivered issue

Hi, I'm developing a system based on Akka and I got stuck with situation which is completely unclear for me. I have three actors with following hierarchy: Root actor - SubPathProcessingSupervisor - SubPathFinderActor. Root actor creates SubPathProcessingSupervisor one during preStart and then