Re: [akka-user] Akka TCP with Actors vs Akka Streams and Flows/Graphs

Hi, Akka streams is defintely fit for "main stream development with semi complex business logic", it is however not a framework but a tool in a toolkit. As such it does have a learning threshold (just like actors do if you are new to that concept), so some problems may not initially be

Re: [akka-user] Re: Tcp TLS example with client auth

Hi Magnus, The TLS stage does actually have some end user documentation, look at the TLS object and its factory methods. We use the TLS module in Akka HTTP so those sources may be interesting to look at. Additionally, if it is just about configuration, then the documentation for the Typesafe SSL

Re: [akka-user] Retry only has meaning for restart in SuperVisorStragety?

Hi Yan, If you choose resume, you think that the actor state is ok, but the message bad, so you don't want to retry the message. If you choose restart then it may have been the actor state that was bad, that will be fixed by the restart and then it may be reasonable to retry the message, if you

Re: [akka-user] Cleanup after HttpResponse

When you do not control the materialization you can attach callbacks to the future when materializing using something like this: .mapMaterializedValue(future => future.alsoTo(someLogicOnCompletion)) -- Johan On Tue, Jul 26, 2016 at 2:47 PM, daleksan wrote: >

Re: [akka-user] Issue with Akka Camel Producer: component is receiving BoxedUnit

Hi Héctor, You are transforming the message from a CamelMessage to a Unit in your method: override def transformOutgoingMessage(msg: Any) = { println(s"${msg.getClass}") } println returns Unit, when interacting with Java the Unit object becomes BoxedUnit as Unit does not exist in Java-land.

Re: [akka-user] Question about Akka Scaling: Memory

definitely worth learning ;) -- Johan Akka Team On Tue, Aug 9, 2016 at 6:43 PM, Rob Crawford <rob5...@gmail.com> wrote: > > > On Tuesday, August 9, 2016 at 11:14:57 AM UTC-4, drewhk wrote: >> >> >> >> On Tue, Aug 9, 2016 at 5:07 PM, Rob Crawford <rob...

Re: [akka-user] how to do a rolling cluster upgrade with marathon?

. This race is essentially what the consistent list of seed nodes initially protects against. -- Johan Akka Team On Tue, Aug 9, 2016 at 12:18 PM, Bert Robben <bert.rob...@gmail.com> wrote: > Hi guys, > > I don't have any seed nodes statically configured. When the cluster > s

Re: [akka-user] Errors using Partition for custom FanOutShape

.from(partition).via(subtract).toFanIn(merge); return new FlowShape<>(partition.in(), merge.out()); })); source.via(flow).runForeach(System.out::println, materializer); -- Johan Akka Team -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >

Re: [akka-user] Akka create two Tcp Connections with the same port

That will only be possible if the hosts resolve to different IP-addresses on the machine they are run on. For example you could create a virtual interface with a separate IP address for one of the hostnames. -- Johan On Mon, Jul 11, 2016 at 9:12 PM, Chris Stewart

Re: [akka-user] Akk Cluster Singletion - Oldest node down message

Hi, In Akka Cluster unreachable and downed are two different things, a node can become unreachable when there is network problems, its JVM is having a long GC pause etc. it may come back from unreachable. Down on the other hand is when a decision has been made about that specific node, that it

Re: [akka-user] Re: How to wait for akka http request

Hi, You are saying "there would be errors", is this something you have seen or are you speculating about the behavior under load? And if it is something seen, what are those errors? -- Johan On Sun, Jul 10, 2016 at 7:25 PM, Sang Dang wrote: > I think you could limit your

Re: [akka-user] Access to LoggingAdapter

If you are writing a custom graph stage, you can access it inside the GraphStageLogic from the ActorSystem like this: materializer match { case mat: ActorMaterializer => mat.logger case _ => throw new RuntimeException("this stage only works with an actor materializer") } Note that this may

Re: [akka-user] Question about akka-http ssl loose config

I think that should work (although, in general you should *always* prefer real certificates or at least go with an internal ca and sign local certs using that, accepting any will allow for man in the middle attacks, spoofing server etc). Did you try and have any problems with it? -- Johan On

Re: [akka-user] Run a Flow with an ActorPublisher as a Source

Hi Oliver, I find it a bit hard to follow your code snippets and what the types are and where the error actually happens. I'd recommend you to add type ascriptions until you see where the inferred type does not match what you thought it would be. So for example: val runnableGraph:

Re: [akka-user] KillSwitch not having an effect

}); > setHandler(out, new AbstractOutHandler() { > > @Override > public void onPull() throws Exception { > pull(in); > > } > }); > } > }; > } > > } -- Akka Team Lightbend &

Re: [akka-user] akka cluster

Hi Maatary, Take a look at the Cluster Metrics, sounds like that could a piece of the puzzle at least: http://doc.akka.io/docs/akka/2.4/scala/cluster-metrics.html -- Johan On Fri, Jul 15, 2016 at 9:20 AM, Maatary Okouya wrote: > Hi, > > I wonder what is the proper way

Re: [akka-user] ShardCoordinator and persistence journal

readable format for the journal (I'm guessing that is what you are after): http://doc.akka.io/docs/akka/2.4/scala/persistence-schema-evolution.html#Store_events_as_human-readable_data_model -- Akka Team Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @ak

Re: [akka-user] Akka create two Tcp Connections with the same port

an't have unique ip addresses that are out on the web? Only ones > that are local to my machine? That seems rather limiting. > > On Thursday, July 14, 2016 at 10:58:08 AM UTC-5, Akka Team wrote: >> >> Akka will work out of the box if the host names resolve to separate ip

Re: [akka-user] Bad example in documentation

/groups.google.com/d/optout. >> > > > > -- > > Patrik Nordwall > Akka Tech Lead > Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM > Twitter: @patriknw > > -- > >>>>>>>>>> Read the docs: http://akka.io/do

Re: [akka-user] Re: How to perform dataset queries with cluster sharding in cqrs?

Take a look at this section of the docs and see if that helps: http://doc.akka.io/docs/akka/2.4/scala/persistence-query.html#Performance_and_denormalization -- Johan On Tue, Jul 5, 2016 at 8:42 AM, Lap Ming Lee wrote: > Another solution I can think of is to forward the

Re: [akka-user] Re: akka-http web socket issue

I have created a ticket for updating the docs about the client example mentioned: https://github.com/akka/akka/issues/20938 As always, contributions are welcome! -- Johan On Thu, Jul 7, 2016 at 7:42 PM, Eric Swenson wrote: > Thanks, Giovanni. That was precisely the problem

Re: [akka-user] Patterns.Ask replacement

Hi Sergey, What are you trying to achieve? In general Streams are geared more for processing pipelines than "get one element"-request-response type of interaction. -- Johan On Tue, Jul 5, 2016 at 9:22 PM, Sergey Sopin wrote: > Hi, > > Is there any possibility to replace

Re: [akka-user] How to add connection.remoteAddress to Http request handler - additional input parameter to Flow

with the remote address before you pass it to your handler. -- Johan Akka Team On Mon, Aug 1, 2016 at 5:54 PM, Zlatko Roncevic <zlatko.ronce...@gmail.com> wrote: > Hi, > > I need origin IP address in my request handler, but I don't know how to > add this parameter ..

Re: [akka-user] Re: No configuration setting found for key 'akka.version' when running jar-with-dependencies

Seems like that. PRs are welcome. For other people interested there is a ticket here: https://github.com/akka/akka/issues/21120 -- Johan Akka Team On Mon, Aug 8, 2016 at 4:58 PM, Dean Schulze <dean.w.schu...@gmail.com> wrote: > I did a copy and paste from the documentation page for th

Re: [akka-user] Re: No configuration setting found for key 'akka.version' when running jar-with-dependencies

is not in your shade output jar. -- Johan Akka Team On Sat, Aug 6, 2016 at 9:36 PM, Dean Schulze <dean.w.schu...@gmail.com> wrote: > I did exactlyl that, and also tried with a newer version of the plugin but > I still get the exception. > > Do I have to roll back to an older versio

Re: [akka-user] Questions on Activator Template: Akka Sample Twitter Streaming

List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

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] Microservices Architecture with AKKA Cluster

p and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/opto

Re: [akka-user] Re: SBT dependencies for Akka Sample Twitter Streaming Activator Template

/ > >>>>>>>>>> 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 su

Re: [akka-user] akka-cluster split brain when enable auto-down and set a node random package loss rate 50%

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

Re: [akka-user] distributed in-memory lru cache using akka cluster

om. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twi

Re: [akka-user] What is ProtocolStateActor.invoke and why is it so time consuming?

se you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this g

Re: [akka-user] Configurable parallelism/elastic groupBy

l to akka-user+unsubscr...@googlegroups.com. >>> To post to this group, send email to akka-user@googlegroups.com. >>> Visit this group at https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> > -- &g

Re: [akka-user] SBT Dependencies need to be updated for Akka Sample Twitter Streaming template on Activator

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 subscribed to the Google Groups > "Akka User List" group. > T

Re: [akka-user] Is Akka the right choice for my simple distributed system?

> --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-

Re: [akka-user] Weakly up feature not working

the cluster does not seem to work. I'll look into this and see if it might be a bug. However, here is a sample that shows weakly up working as expected, downing a node so it becomes unreachable, and then joining a new node: https://gist.github.com/johanandren/04c4720c917bad167169f73abe68da03 -- Johan Akka

Re: [akka-user] Logging outside Actors, namely within your scalaTest

Did you look at the scaladoc of LogSource like the exception told you to? It contains an explanation of to provide a log source for any kind of type. system.log will work fine as well though, as long as you don't want a specific log source in your log entries logged from the test. -- Johan Akka

Re: [akka-user] Database query does not cancel when streaming rows using a DatabasePublisher

pon application start and subscribe to that multiple time like you do now but rather once for every request that comes in to webservice/csv (so inside the block of the get directive. -- Johan Akka Team On Wed, Feb 1, 2017 at 3:27 PM, Mark Goldenstein <bigande...@gmail.com> wrote: > Hi guys! > &

Re: [akka-user] Balancing TCP requests

It looks correct to me, what is it that makes you think it is not the server closing the connection as the exception says? -- Johan Akka Team On Thu, Jan 26, 2017 at 3:20 PM, Maksym Besida <maks.bes...@gmail.com> wrote: > Based on this paragraph > <http://doc.akka.io/docs/ak

Re: [akka-user] Chunked Response handling with Akka Http?

ake a look at Source.unfoldAsync, Source.unfoldResourceAsync and Source.queue and see if either of those fit your use case. -- Johan Akka Team On Mon, Jan 16, 2017 at 8:03 AM, <subo...@gmail.com> wrote: > I'd like to be able to use akka-http with chunked responses. I'd like to know > if I can do the s

Re: [akka-user] Class cast exceptions in actors that return Future[Unit]

You have a Future[Something], and a Something is an Any (everything is) but it is not Unit (only Unit is), so you can not just cast it, you must replace it with an actual Unit, which is what .map(_ => ()) does. -- Johan Akka Team On Tue, Jan 31, 2017 at 11:35 AM, Alan Burlison <alan

Re: [akka-user] Class cast exceptions in actors that return Future[Unit]

If it in fact was a Unit you got back from the actor then neither of the things you tried should throw a class cast exception though. If the actor for example sends a Future[Unit] back, then you will have a Future[Future[Unit]] returned from ask. -- Johan Akka Team On Tue, Jan 31, 2017 at 2:41

Re: [akka-user] streams: why pulls the concat combinator both sides eagerly and the merge combinator not

I agree that it would be good if it was documented, please open a ticket (and even better a ticket AND a PR adding docs) -- Johan Akka Team On Thu, Jan 19, 2017 at 3:01 AM, EXTERNAL Wachter Stefan (Keybird IT Consulting und Vetriebs GmbH, INST-ICM/BSV-BS) < external.stefan.wach...@bosch-si.

Re: [akka-user] Akka Cluster and custom code deployment (transfer the classes to the nodes to start new actors at runtime)

Hi, Nothing like that in Akka. Remote class loading has been done in the JVM before, but since it can easily allow a remote attacker full freedom to run any code they want on a server node it's not very common any more. -- Johan Akka Team On Fri, Jan 27, 2017 at 9:17 PM, Eugene Dzhurinsky

Re: [akka-user] Declare Mailboxes Programmatically

The only way currently would be to programatically generate the config entries for the mailboxes before starting the actor system. -- Johan Akka Team On Sat, Jan 28, 2017 at 4:33 AM, Edoardo Vacchi <evac...@live.com> wrote: > I know that a mailbox can be selected through > Props.

Re: [akka-user] What means of akka cluster roles leader?

/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 subscribed to the Google Groups > "Akka User List" g

Re: [akka-user] Re: How do I implement "Lookup or Create actor" pattern

a.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 ar

Re: [akka-user] Do we rename the actor instance's name.

kka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send

Re: [akka-user] Basic Akka stream server not receiving data sent by client

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

Re: [akka-user] Basic Akka stream server not receiving data sent by client

y he gets away with it, it is racy. I guess we should provide some helpers for the case when one only wants to read from TCP and close the output when the other side closes. -Endre > > -chhil > > On Friday, August 19, 2016 at 2:54:36 PM UTC+5:30, Akka Team wrote: >> >>

Re: [akka-user] What happened if leader become unreachable in the cluster

gt;>>>>>>>> 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 subscribed to the Googl

Re: [akka-user] Router path in Akka config

;>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>> urrent/additional/faq.html >>> >>>>>>>>>> Search the archives: https://groups.google.

Re: [akka-user] [akka-streams] Wrapping one flow with another while keeping the inner's materialized value

p/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to

Re: [akka-user] Custom GraphStage with async operation

.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to

Re: [akka-user] How do we handel OversizedPayloadException in Akka

>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>>>>> urrent/additional/faq.html >>>>>> >>>>>>>>>> Search the archives: https://groups.google.com/grou >>>>>> p/akka-user >>>>>> --- >>&g

Re: [akka-user] How do we handel OversizedPayloadException in Akka

code, I see a bunch of throw clauses. My point > is that if such an exception occurs, currently it is just logged, there is > no failure or error anywhere, just a message in the log. Now that becomes > a hard to track issue > > > On Monday, August 22, 2016 at

Re: [akka-user] akka connection refused with a shared actorRef

. As the protocol is p2p both sides of a connection must be able to connect to the other, something that is usually not possible with NAT unless you specificly configure the router to forward the specific port to a computer inside of the NAT. -- Johan Akka Team On Sat, Aug 27, 2016 at 10:58 AM, Loïc

Re: [akka-user] Re: Akka and Streams Concurrency Fundamentals

Hi Dagny, The Akka Streams tests for the built in stages could perhaps be useful to see various strategies for testing. You can find those sources here: https://github.com/akka/akka/tree/master/akka-stream-tests/src/test/scala/akka/stream/scaladsl -- Johan Akka Team On Fri, Sep 2, 2016 at 8:08

Re: [akka-user] Catch dropped elements in a stream

be done with a custom stage that looks at the previous id and the current. Depending on use case there might be more strategies that could achieve what you want. -- Johan Akka Team On Wed, Aug 31, 2016 at 1:16 PM, Victor <victor.pi...@iadvize.com> wrote: > Hi, > > I've designed an AMQ

Re: [akka-user] [akka-http] what is actually happening on request timeout?

pull(in) } override def onDownstreamFinish(): Unit = { println(s"$name: onDownstreamFinish") super.onDownstreamFinish() } }) } } -- Johan Akka Team On Sat, Aug 27, 2016 at 10:25 PM, Kyrylo Stokoz <k.sto...@gmail.com> wrote: > HI All, >

Re: [akka-user] Cannot configure mailbox for Routees in RoundRobinPool

"/groupedtestactor/*" { mailbox = bounded-mailbox } Since the pool will create the routees as children this configures all direct children of the router to use the bounded-mailbox -- Johan Akka Team On Fri, Aug 26, 2016 at 2:53 PM, Mehmet Cem Güntürkün < mehmetcemguntur...@gmail.com>

Re: [akka-user] Exception during creation of ActorReceiver in Spark CDH 5.5.2

parameter being a specific lambda expression, so something about serializing lambdas. The chances of getting a good answer may be better in a more Spark focused forum (see here: https://spark.apache.org/community.html) -- Johan Akka Team On Wed, Aug 31, 2016 at 12:56 AM, Ricky <ricky.pri

Re: [akka-user] akka-http how to allow idle connections while limiting the total number of responses being rendered

reuse, so that the same atomic int is used val maxOneConcurrent = createConcurrentLimiter(1) val route = get { extractRequest { req => maxOneConcurrent { // never more than one in here complete("ok") } } } -- Johan Akka Team On Mon, Sep 5, 2016 at 3:56 PM, 'R

Re: [akka-user] Example of stateful BidiFlow

/One2OneBidiFlow.scala -- Johan Akka Team On Wed, Sep 7, 2016 at 2:26 PM, Yaroslav Klymko <t3h...@gmail.com> wrote: > Hi Guys, > Is there somewhere an example of stateful BidiFlow ? > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ >

Re: [akka-user] Re: How to Test WebSocket Streams

-docs/rst/scala/code/docs/http/scaladsl/server/directives/WebSocketDirectivesExamplesSpec.scala -- Johan Akka Team On Wed, Aug 31, 2016 at 10:32 PM, Dagny T <dagnytagg2...@gmail.com> wrote: > > TYPO! My latest WebSocketServer experiment is ACTUALLY in: > - streamsWebSocket.scala &

Re: [akka-user] GPU computing with akka

Hi Zhaoije, No we are not working on anything like that, and the project mentioned does not seem to have been touched in the last 5 years. If there are JVM libraries that can do GPU processing there is nothing stopping you from using it from actors/Akka though. -- Johan Akka Team On Thu, Sep 8

Re: [akka-user] Re: Kryo serialization not working?

Good that you figured it out, and thanks for sharing what was wrong rather than leaving the question open! -- Johan Akka Team On Fri, Sep 9, 2016 at 2:28 AM, Federico Nusymowicz <feden...@gmail.com> wrote: > DERP. I was supposed to nest serializers and serialization-bindings under >

Re: [akka-user] GPU computing with akka

No, no plans currently -- Johan Akka Team On Fri, Sep 9, 2016 at 4:02 AM, Zhaojie Niu <nzjem...@gmail.com> wrote: > Dear Johan: > > Thanks for your reply. > > Does Akka team have any plans to support GPU? > > 在 2016年9月8日星期四 UTC+8下午10:08:32，Akka Team写道： &g

Re: [akka-user] Re: Testing routes and marshalling

. -- Johan Akka Team On Wed, Sep 7, 2016 at 1:47 AM, Richard Rodseth <rrods...@gmail.com> wrote: > Oy. I'm getting tied up in knots. I guess the requestHandlerProbe.reply > won't work without a proper sender. I usually put my route definition in an > actor, but moved i

Re: [akka-user] Akka HTTP complete Future obtained from ask, with custom marshalling

You can still pattern match on the type, like so: case result: SomeType => complete(result) -- Johan Akka Team On Fri, Oct 7, 2016 at 4:30 PM, Richard Rodseth <rrods...@gmail.com> wrote: > You're right the types are different, and PimpedResult is not a case class > so p

Re: [akka-user] Akka HTTP complete Future obtained from ask, with custom marshalling

Hi Richard, You can combine ask with mapTo to cast it to the right type (or fail the future if it does not have that type), see the docs here: http://doc.akka.io/docs/akka/2.4/scala/futures.html#use-with-actors -- Johan Akka Team On Fri, Oct 7, 2016 at 10:55 AM, Richard Rodseth <rr

Re: [akka-user] Re: Organizing Route Directives

y do separate concerns in your codebase, think about using the same way for routes rather than introducing an entirely different way to do that. -- Johan Akka Team On Fri, Oct 7, 2016 at 11:09 AM, <jpsteinm...@skydance.com> wrote: > Yes I understand that much and I have broken up

Re: [akka-user] Akka streams in web application

with. -- Johan Akka Team On Thu, Sep 29, 2016 at 6:29 AM, Madabhattula Rajesh Kumar < mrajaf...@gmail.com> wrote: > Hi, > > I am planning to use Akka Streams in web application. Below is my use case. > > Whenever the request come to web server, I will do some operations like >

Re: [akka-user] XMPP API development in Scala

spontaneously seems to make sense), make sure to check out the blog post series about writing connectors on the Akka team blog: http://blog.akka.io/integrations/2016/08/23/intro-alpakka http://blog.akka.io/integrations/2016/08/29/connecting-existing-apis http://blog.akka.io/integrations/2016/09/05

Re: [akka-user] Re: Organizing Route Directives

) The testkit only needs the Route instance, so again, no requirement to be in a trait or any other construction setup there. -- Johan Akka Team On Fri, Oct 7, 2016 at 12:15 PM, Richard Rodseth <rrods...@gmail.com> wrote: > Isn't it true that your routes need to be in a trait t be abl

Re: [akka-user] Re: [akka-stream] How to implement Spark's cogroup/join operation

is likely not a good option for you to achieve this, I'd say a custom graph stage would be the way to go if you need to do it with streams, or just folding over some suitable datastructure where you can collect elements per key. -- Johan Akka Team On Thu, Sep 29, 2016 at 11:03 AM, Jakub Liska

Re: [akka-user] Akka HTTP complete Future obtained from ask, with custom marshalling

To be fair you are doing something pretty complex with them, but I agree, the magnet pattern definitely can be humbling. Did the code that worked just fine earlier really deal with the exact same type (tuple with statuscode and APIError)? -- Johan Akka Team On Fri, Oct 7, 2016 at 1:30 PM

Re: [akka-user] Re: WebSocket closed immediately after upgrade

Did you try running your source, sink and actor without Akka HTTP in a unit test or such and verify that they work as you expect? -- Johan Akka Team On Sat, Sep 24, 2016 at 3:25 AM, Dan Ellis <d...@danellis.me> wrote: > Originally on 2.4.7, but I just checked with 2.4.10 and I get

Re: [akka-user] missing type akka.stream.impl.VirtualProcessor$WrappedSubscription$$SubscriptionState

Sounds like you may be mixing different versions of Akka modules, make sure to use a single Akka version across the board. -- Johan Akka Team On Mon, Sep 26, 2016 at 11:20 AM, <external.stefan.wach...@bosch-si.com> wrote: > Hi all, > > > > starting an application I see the

Re: [akka-user] some particular dead letters not being sent to eventstream.

Hi Sudeep, That should not happen in any circumstance as far as I can see. Are you sure your configuration to use the bounded mailbox is correct and actually applies to the actor you are testing? -- Johan Akka Team On Sun, Sep 11, 2016 at 7:24 AM, Sudeep Khemka <sudeep.ju...@gmail.com>

Re: [akka-user] Akka scheduler

Hi Jose, There are to few details in the provided code sample to say for sure, it depends on what your Routing actor does when handleMessage returns and also how your SpringExtension integration works. -- Johan Akka Team On Tue, Sep 13, 2016 at 4:58 PM, José Diaz <jose.d...@joedayz.pe>

Re: [akka-user] How to Increase (AKKA-HTTP Client) singleRequest response chuck size

can make the chunks smaller. Can you tell us a bit more about why you want larger chunks and maybe it will be easier to give you some ideas about how you can achieve that? -- Johan Akka Team On Wed, Sep 7, 2016 at 11:27 PM, Tal Beno <tal.b...@gmail.com> wrote: > I am reading an HTTP

Re: [akka-user] the meaning of Actor.receive and context.become

Hi Bert, There is no public access to the current behaviour of the actor in the API so this you would have to implement yourself. -- Johan Akka Team On Fri, Sep 30, 2016 at 3:07 AM, Bert Robben <bert.rob...@gmail.com> wrote: > > I'm puzzled by the meaning of Actor.receive() and co

Re: [akka-user] Akka-remote docker<->docker works fine with netty.tcp, but fails with artery - ideas?

at/why/how it is not working. -- Johan Akka Team On Wed, Nov 9, 2016 at 7:14 PM, <johan.kjolhede.bonniern...@gmail.com> wrote: > Yes - i Did. Please see my original post for details. You will see that I > use the udp parameter for my docker port forwarding. Also please note that > I've t

Re: [akka-user] Akka-remote docker<->docker works fine with netty.tcp, but fails with artery - ideas?

Hi Johan (good name!), Artery/Aeron uses UDP, while the old remoting is TCP-based, did you configure your docker nodes with udp port mappings? -- Johan Akka Team On Wed, Nov 9, 2016 at 6:11 PM, <johan.kjolhede.bonniern...@gmail.com> wrote: > I'm pretty new to Akka and am currently t

Re: [akka-user] Website Correction / http://akka.io/docs/

/akka/tree/master/akka-docs https://github.com/akka/akka-http/tree/master/docs -- Johan Akka Team On Tue, Nov 8, 2016 at 6:35 AM, Gavin Baumanis <gavinbauma...@gmail.com> wrote: > I would have happily created a PR but i couldnt find the documentation in > the github repo. > > If

Re: [akka-user] How can I check that MemberUp(m:Member) does not equal self actor?

Hi, Cluster.selfAddress will give you the address of the actor system, and then you can compare it to Member.address -- Johan Akka Team On Mon, Nov 7, 2016 at 6:18 AM, Unknown Unknown <zx80l...@gmail.com> wrote: > There is the following actor which belongs to cluster and is s

Re: [akka-user] StreamSupervisor name

ementation detail, but perhaps you can provide some addition to the string "end-of-lookup" to give you context in the log entry? -- Johan Akka Team On Wed, Nov 9, 2016 at 6:33 PM, Richard Rodseth <rrods...@gmail.com> wrote: > I'm trying to write two ScalaTest tests to compare two a

Re: [akka-user] Re: Akka persistence query examples

after adding functionality for example). Another could be to persist the read side in some other way, a relational database for example and do queries against that. -- Johan Akka Team On Wed, Nov 9, 2016 at 5:34 PM, Juan Carlos Roig <jcr...@gmail.com> wrote: > Hi everyone. Just

Re: [akka-user] Re: Replaying journal events without actually recovering Actors?

val allPersistenceIDs = readJournal.allPersistenceIds() >> val dafuq = >> readJournal.eventsByPersistenceId(PersistCompatIT.lamePersistActorID) >> println("Found persistence IDs:") >> allPersistenceIDs.map { e => >> println(e) >

Re: [akka-user] Resumable Projection

ail to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @akkateam -- >>>>>

Re: [akka-user] `ActorSystem.whenTerminated` hangs indefinitely if called from an `registerOnTermination` callback

>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to

Re: [akka-user] Re: BidiFlow from custom GraphStage join connection pool flow

"Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. &

Re: [akka-user] Re: Is back pressure triggered upon exceptions

hanks, and really appreciate your time! >>> >>> Kunal >>> >> -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/ > current/additiona

Re: [akka-user] Failing to see router configuration when using context.ActorOf(FromConfig.props(Props[LogWorker]),"logWorker")

.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 subscribed to the Google Groups > "Akka User List" group. > To unsub

Re: [akka-user] graph control events propagation

esigned :D -Endre On Tue, Oct 18, 2016 at 9:43 PM, Kyrylo Stokoz <k.sto...@gmail.com> wrote: > Hi Akka Team, All, > > I have few custom stages, recently i find out that one of them under > certain conditions was not properly completing graph stage, which was > causing graph to

Re: [akka-user] Strange test failure in `Flow.filter(..)` with test-kit TestSink

ou received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegrou

Re: [akka-user] Unidirectinoal WebSocket in Java

le Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.co

Re: [akka-user] [akka-cluster]How is the Terminate message issued to its watcher if wachee is closed during the unreachable period?

gt; >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails f

Re: [akka-user] Cluster Sharding custom routing

$$ShardAllocationStrategy ) -- Johan Andrén Akka Team On Tue, Dec 6, 2016 at 7:13 PM, Luis Pedrosa <lpedros...@gmail.com> wrote: > Hello! > > > From what I understand, the cluster sharder GracefulShutdown > implementation, removes the node from the cluster. It also signals all the > remai

<    2   3   4   5   6   7   8   >