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

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] Unable to listen ClusterClientUp Event

SubscribeClusterClients should be sent to the receptionist, you are sending it to your PingPongActor. -- Johan -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the

Re: [akka-user] Microservices Architecture with AKKA Cluster

? The same cluster should not be used for multiple micro-services ? Does > that also means that each microservice should be fully self contained, > running on its on instance of akka-http i.e. http server ? > > On Friday, July 22, 2016 at 5:44:15 AM UTC-4, Akka Team wrote: >> >>

Re: [akka-user] Re: Akka Java IO TLS

The easiest path would probably be Akka Streams for TCP ( http://doc.akka.io/docs/akka/2.4/scala/stream/stream-io.html) and the existing TLS graph module ( http://doc.akka.io/api/akka/2.4/#akka.stream.scaladsl.TLS$). There isn't much documentation on the TLS module, but you should be able look at

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] from spray to akka http - multi layer routes with actors

The HttpService trait in Spray is a pretty thin thing, so if you really like that style you can probably mimic it yourself to get the corresponding setup with Akka HTTP, read up on the Http API of Akka and take a look at the Spray sources and you should be able to figure it out. The big

Re: [akka-user] Akka in a home automation system

Hi Michael, This is the Akka project mailing list (the JVM based one), Akka.NET is actually an entirely separate project, mailing list is over here: https://groups.google.com/forum/#!forum/akkadotnet-user-list Nothing obviously making what you describe a bad fit with an actor system in general.

Re: [akka-user] Re: Unit test akka persistence against the inmem journal

Did you consider just restarting the persistent actor and observing that it reaches the right state? You could in fact even start a completely different actor with the same persistenceId and just collect the replayed events for inspection. -- Johan On Tue, Jul 26, 2016 at 10:12 PM, Paweł Kaczor

Re: [akka-user] Type mismatch, expected: ToResponseMarshallable, actual: WebServer.Item

Hi Ajinkya, The sample works copied verbatim from your mail. Additionally the example sources you copied it from is part of our Akka build and does indeed also compile. Something must be wrong with your local environment, have you added the akka-http-spray-experimental module as a dependency?

Re: [akka-user] getting out of memory - not able to create new native threads in akka java

Hi Jitu The thread pool based dispatcher is best suited to isolate blocking actors from the rest of the system, it has an upper limit on the number of threads you can set with max-pool-size-max so you can guarantee that the number of threads are not growing without control. Getting OutOfMemory

Re: [akka-user] Question about how to use PeekMailBox

Hi Yan, I'd recommend you to try to start out with some messaging pattern instead of reaching for special mailboxes. Did you try just catching the exception and retrying your logic rather than relying on supervision for this? A second option would be to have the sender retry sending the message

Re: [akka-user] Akka Streams as an ETL tool?

mples of more complex patterns I've > been using. Do you have a preference on how cookbook examples are > submitted? > - James > > On Jul 22, 2016 5:46 AM, "Akka Team" <akka.offic...@gmail.com> wrote: > >> Hi James >> >> On Thu, Jul 14, 2016 at 1

Re: [akka-user] Stream API Fundamentals: Activator Template on Akka Http with Websockets

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

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] 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] 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] 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] 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] 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] 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] 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] 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] 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] 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] 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] 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] 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] 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] KillSwitch not having an effect

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

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] 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] Akka Sen email alerts

Any Java SMTP client would do, if it is blocking, make sure that the actor using it runs on a separate thread pool dispatcher rather than the default fork join pool. Except for this nothing special about using them from Akka. A google search will probably give you a lot of options to choose from.

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

u, I NEED to create this virtual > interface if the hosts resolve to different ip addresses, or akka should > work out of the box if the hosts resolve to different ip addresses. > > On Tuesday, July 12, 2016 at 8:32:08 AM UTC-5, Akka Team wrote: >> >> That will only

Re: [akka-user] Access to LoggingAdapter

Cheers, > √ > On Jul 14, 2016 08:39, "Akka Team" <akka.offic...@gmail.com> wrote: > >> If you are writing a custom graph stage, you can access it inside the >> GraphStageLogic from the ActorSystem like this: >> >> materializer match { &

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

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] handling 2 receive functions for an actor

A Receive is just a PartialFunction[Any, Unit], so combinators on partial functions can be used. For example: oneReceive.orElse(anotherReceive) which will fall back to the second receive if there is no matching case in the first one. If you want to dynamically combine a receive with another that

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] 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] 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: really strange MatchError - scala.MatchError: None (of class scala.None$)

> { override def newInstance(c: Class[_]): AnyRef = None } > > ) > > > > Thanks for your help > > --Stefan > > Am Donnerstag, 9. Juni 2016 12:18:56 UTC+2 schrieb Akka Team: >> >> Hi Stefan, >> >> That looks really weird. What it seems like tha

Re: [akka-user] Newbie question about storing ActorRef in a member variable

ps.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 e

Re: [akka-user] Re: two-way on websocket

gt; >> >> Its connect well but not keep connected :( . Can anyone help me on that ? >> >> Thanks! >> > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > htt

<    1   2   3   4   5   6   7   8   >