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.
>
the exact design of the sample, but maybe ideas
in it may prove valuable.
--
Johan
Akka Team
On Thu, Feb 22, 2018 at 10:35 PM, Grace <alohagraceal...@gmail.com> wrote:
> Thanks Patrik.
>
> In my use case, I have a few hundreds of client nodes. I have about 300
> worker nodes acr
Maybe this distributed workers guide could be good inspiration:
https://developer.lightbend.com/guides/akka-distributed-workers-scala/
--
Johan
Akka Team
On Fri, Feb 2, 2018 at 3:10 AM, Konrad “ktoso” Malawski <
konrad.malaw...@lightbend.com> wrote:
> Have a look at "cluster s
Did you see the Mutual Auth section in the Akka HTTP docs?
https://doc.akka.io/docs/akka-http/10.0.11/scala/http/server-side/server-https-support.html#mutual-authentication
The synthetic Tls-Session-Info header should give you access to the client
certs etc.
--
Johan
Akka Team
On Mon, Jan 29
are doing. If this is the problem the solution
would be to not block or to run such things on a separate thread pool based
dispatcher.
--
Johan
Akka Team
On Tue, Jan 16, 2018 at 8:37 PM, <abhil...@zilingo.com> wrote:
> Hey Folks,
>
> I've been working on a service thats built on Scal
the logic before the request execute in parallel with
the request being executed.
--
Johan
Akka Team
On Tue, Jan 9, 2018 at 4:23 AM, kor <khalid.r...@gmail.com> wrote:
> Hello all. I have a requirement where I need to stream records from a
> couchbase database, do some json transformati
.
Work pulling is also almost always a better to organize work than balancing
as it allows the worker to apply back pressure, see the distributed worker
sample for one example of that:
https://developer.lightbend.com/guides/akka-distributed-workers-scala/
--
Johan
Akka Team
On Wed, Dec 13, 2017
thread instead, thanks!
--
Johan
Akka Team
On Sun, Jan 28, 2018 at 12:48 PM, Thai <lgoptimusv...@gmail.com> wrote:
> Hi Mathieu,
>
> Sorry to re-open a quite old topic. I'm looking for an example exactly
> like this one "*a websocket server for which there is no 1-1 rela
op 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/optout.
>
I think the floodPipe benchmark may do what you want, commented out but you
could easily uncomment and run locally:
https://github.com/akka/akka/blob/master/akka-bench-jmh/src/main/scala/akka/actor/ForkJoinActorBenchmark.scala#L92
--
Johan
Akka Team
On Fri, Dec 15, 2017 at 11:20 AM, <k
What is happening when you run the code and how is that different from what
you expect?
--
Johan
Akka Team
On Mon, Aug 7, 2017 at 2:16 PM, G J <me.gaura...@gmail.com> wrote:
> I'm new Akka stream, I have to build on poc on Akka stream for instant
> messaging. So I need a help to und
No current plans about anything specifically related to interacting with
persistent actors, couldn't batch + mapAsync(1)(ask-persistent-actor) do
what you want?
--
Johan
Akka Team
On Wed, Sep 13, 2017 at 3:50 PM, <techland.co...@gmail.com> wrote:
> I have the same question ?
>
&g
exploring.
--
Johan
Akka Team
On Tue, Oct 31, 2017 at 9:49 PM, Jason Steenstra-Pickens <
thestein...@gmail.com> wrote:
> Hi Johan,
>
> As far as I can tell this only creates a single Sink based on the first
> element. I need a dynamic number of Sinks. In the past I have used
Check if sink.lazySink.lazyInit() doesn't do what you want.
--
Johan
Akka Team
On Tue, Oct 31, 2017 at 12:59 AM, Jason Steenstra-Pickens <
thestein...@gmail.com> wrote:
> Hi,
>
> I seem to be encountering a reoccurring problem when using Akka Streams
> and haven't found th
The HTTP/2 support in Akka HTTP is so far only server side, there is no
client implementation. So you would have to use some other HTTP client to
achieve that for now.
--
Johan
Akka Team
On Wed, Sep 6, 2017 at 2:50 PM, <mahesh.b...@wingify.com> wrote:
> Hi Friends,
>
> I have
with.
--
Johan
Akka Team
On Wed, Sep 13, 2017 at 4:01 PM, <techland.co...@gmail.com> wrote:
> Someone who can help me ???
>
> On Saturday, September 2, 2017 at 3:53:20 PM UTC+4:30,
> techlan...@gmail.com wrote:
>
>> hi every one
>> I'm using akka 2.5.x h
wouldn't want to stop it. If the failure
could have damaged the internal state you would want to restart etc.
--
Johan
Akka Team
On Mon, Aug 21, 2017 at 3:02 PM, Isaias Barroso <isaias.barr...@gmail.com>
wrote:
> Hi, all.
>
> Suppose I have an actor and I need to interrupt an
-on-default-dispatcher
--
Johan
Akka Team
On Fri, Sep 8, 2017 at 10:00 AM, 'Simon Jacobs' via Akka User List <
akka-user@googlegroups.com> wrote:
> Hy there,
>
> I have an akka scheduler to reindex some data in the search-engine and to
> resize the images of every user.
>
> It
tMapConcat(in =>
StreamConverters.fromInputStream(() => creatingInputSource(in)))
--
Johan
Akka Team
On Sun, Sep 3, 2017 at 1:32 AM, Maatary Okouya <maatarioko...@gmail.com>
wrote:
> Hi,
>
> I am trying to figure out how to handle a situation where in one of your
> stage y
.{batchWeighed, conflate, grouped, groupedWithin} to possibly make it a
bit faster.
--
Johan
Akka Team
On Sat, Sep 2, 2017 at 6:56 AM, Bwmat <bwmat.reloa...@gmail.com> wrote:
> Also, I'm curious how backpressure works in the created stream, especially
> the child Iterator; does it onl
ActorRef for
example, so that you can look it up when the Terminated message arrives.
--
Johan
Akka Team
On Mon, Aug 7, 2017 at 9:28 PM, Joe San <codeintheo...@gmail.com> wrote:
> I have a scenario where I have to restart a child Actor from within a
> parent actor. The restart s
body to $path")
onSuccess(bytes.runWith(FileIO.toPath(path))) {
case IOResult(count, Success(Done)) =>
complete(s"Successfully wrote $count bytes to $path")
case IOResult(_, Failure(ex)) => throw ex
}
}
}
}
aterialization.
>
> понедельник, 7 августа 2017 г., 15:49:06 UTC+3 пользователь Akka Team
> написал:
>>
>> You can achieve this by using Sink.last which will materialize into a
>> Future[T] that completes with the last element emitted.
>>
>> It doe
As far as I can see the supervisor never sends any messages to the child,
so that would be why the child inbox is empty?
--
Johan
Akka Team
On Mon, Aug 7, 2017 at 9:32 AM, Nishant Vishwakarma <nishant...@gmail.com>
wrote:
> Hi Konrad,
>
> Thanks for the reply. Meanwhile I a
of exceptions that is doable.
This means that currently if you want to do some more logic with an
exception you would have to catch it.
--
Johan
Akka Team
On Sat, Jul 29, 2017 at 5:53 PM, NISHANT VISHWAKARMA <nishant...@gmail.com>
wrote:
> Hi Team,
>
> I need to get the details
Just tell would be enough: other ! GetUpdate(ctx.self)
--
Johan
Akka Team
On Fri, Aug 4, 2017 at 4:44 PM, Qux <angizi...@gmail.com> wrote:
> Hi,
> I have something like this:
>
> Actor.immutable[Msg]((ctx, msg) =>
> msg match {
> case DoUpdate =>
> v
request. If done by just queueing up
requests (or blocking the incoming thread) and you have a consistent higher
inflow of requests than the limited rate those queued requests may fill up
your heap and crash the JVM or make the HTTP endpoint unavailable by taking
up all the threads.
--
Johan
Akka
d when a thread is available.
If you want to limit the number of requests to a specific number and fail
additional requests rather than queue them up you can do that with a custom
directive like this:
https://gist.github.com/johanandren/b87a9ed63b4c3e95432dc0497fd73fdb
--
Johan
Akka Team
On Tue,
accept a
Try[YourThing] and do the pattern matching on the success/failure there and
then just use pass the invoke method as parameter to Future.onComplete.
--
Johan
Akka Team
On Sun, Aug 6, 2017 at 12:34 AM, Gary Struthers <agilej...@earthlink.net>
wrote:
> GraphStageLogic has getAsyn
pty }) making sure any upstream failure leads to a completion
of the stream.
--
Johan
Akka Team
On Sat, Jul 29, 2017 at 8:17 AM, Alexey Shuksto <seig...@gmail.com> wrote:
> Hello hAkkers,
>
> In our project we use some number of flows that follow same building logic:
> ```
rectly to a file you would do something like
this:
val futureWriteResult: Future[IOResult] =
byteSource.runWith(FileIO.toPath(uploadFile))
--
Johan
Akka Team
On Fri, Aug 4, 2017 at 7:01 AM, <mahadev.khap...@gmail.com> wrote:
> Does Akka directive "fileUpload" copies the
like that.
--
Johan
Akka Team
On Thu, Jul 20, 2017 at 9:21 AM, Olivier Pharabot <
olivier.phara...@gmail.com> wrote:
> All,
>
> I am facing a very confusing issue between two systems, and i came to a
> conclusion that may be someone could confirm (or not).
> I am runni
-and-akka-actors-part-i/
--
Johan
Akka Team
On Thu, Jul 6, 2017 at 7:43 PM, Lap Ming Lee <lapming@gmail.com> wrote:
> I cannot stop an actor running akka stream even with killswitch. How do I
> properly stop an actor running an akka stream?
>
> private def startStream(m
The getting started guide is a good place to get started ;)
http://doc.akka.io/docs/akka/current/java/guide/introduction.html
--
Johan
Akka Team
On Thu, Jul 13, 2017 at 7:02 PM, Bharath Kandaswami <bharath.so...@gmail.com
> wrote:
> Hi Folks,
>
> I am a newbie to Akka, just wa
by taking a thread dump, you should be
able to see your own logic in one of the stack traces hinting you towards
what is wrong.
--
Johan
Akka Team
On Thu, Jul 13, 2017 at 4:59 PM, usermda <shruti.palshi...@gmail.com> wrote:
> Hello
>
> I started getting this warning with
a chance
decide what to do.
--
Johan
Akka Team
On Tue, Jun 27, 2017 at 6:33 PM, Christophe Pache <chpa...@gmail.com> wrote:
> The difference seams to come from that (using request logging):
> HttpEntity.Strict(application/x-www-form-urlencoded; charset=UTF-8,foo=bar
&
Just in case someone has the same problem and comes here, Lantz has since
reported a ticket that you can follow about this:
https://github.com/akka/akka/issues/23072
--
Johan
Akka Team
On Wed, May 31, 2017 at 12:08 PM, lantz moore <lantz.mo...@gmail.com> wrote:
> i'd like to consume
and restart.
--
Johan
Akka Team
On Sat, May 6, 2017 at 4:12 PM, Urvi <upatel...@gmail.com> wrote:
> Hello,
>
> I have a MasterActor where a router is defined and that is where I defined
> the following supervisionStrategy:
>
> override val supervisorStrategy =
Thanks for letting us know, looking into it.
--
Johan
Akka Team
On Fri, Jun 9, 2017 at 10:37 AM, 'Michal Borowiecki' via Akka User List <
akka-user@googlegroups.com> wrote:
> http://developer.lightbend.com/docs/alpakka/current/ started giving a 404.
>
> I looked if it
the executor which has more threads than the requested
workerCount. If unsure, use Executors.newCachedThreadPool().
--
Johan
Akka Team
On Fri, Jun 2, 2017 at 5:15 AM, Yutao <szqs...@gmail.com> wrote:
>
> Here is the Exception:
>
> Exception in thread "main" java.util
connections are killed by the server so that new
requests through the pool triggers new requests which should then end up in
the new service?
--
Johan
Akka Team
On Tue, May 30, 2017 at 9:21 PM, Jorge Fuentes <jfuentes...@gmail.com>
wrote:
>
> Hi here,
>
> I have a service run
ing the stage actor ref (see docs here:
http://doc.akka.io/docs/akka/current/scala/stream/stream-customize.html#integration-with-actors
)
--
Johan
Akka Team
On Thu, Jun 1, 2017 at 7:21 PM, Mohnish Kodnani <mohnish.kodn...@gmail.com>
wrote:
> Hi ,
> I have the following use case that
I think this is because of https://github.com/akka/akka/issues/22324
It was marked as in progress but it seems there never was a PR submitted to
fix that.
--
Johan
Akka Team
On Wed, Jun 7, 2017 at 12:16 PM, <ciet...@gmail.com> wrote:
> yes, *situation 1 *, the log has tell me the rea
The error message says that you have not configured serialization for the
message sample.distributeddata.ReplicatedCache.PutInCache which something
tries to send between nodes.
--
Johan
Akka Team
On Tue, May 30, 2017 at 10:37 PM, Mainak Ghosh <famousmai...@gmail.com>
wrote:
> Hello,
Seems like a regression to me. I have opened an issue to track it here:
https://github.com/akka/akka-http/issues/1179
--
Johan
Akka Team
On Tue, May 2, 2017 at 8:33 PM, richard <harold.richard.sea...@gmail.com>
wrote:
> This document
> <http://doc.akka.io/docs/akka-http/10.0.5
I think that is probably an oversight. Please open a ticket over at the
ssl-config project: https://github.com/typesafehub/ssl-config
--
Johan
Akka Team
On Thu, Mar 23, 2017 at 3:57 PM, Aaron Broad <aaron.br...@gmail.com> wrote:
> Hi all,
>
> I'm creating actors, where each A
/routing-dsl/source-streaming-support.html#source-streaming
--
Johan
Akka Team
On Wed, Apr 26, 2017 at 1:22 PM, <nikhl...@ebctechnologies.com> wrote:
> Hi,
>
> I am using akka http for graphql sangria subscription.
> It is working fine in example application but while i
I think that would be more API surface than we'd like, but please open a
ticket over at https://github.com/akka/akka/issues and we can discuss if it
is worth doing there.
--
Johan
Akka Team
On Tue, Mar 14, 2017 at 11:14 PM, Richard Ney <kamisama@gmail.com>
wrote:
> I was wondering
The problem is that Future is not really suited for asynchronous work
since there is no way to chain actions onto it, the only thing you can do
is to poll or block until it is completed. It would have to be
CompletableFuture.
--
Johan
Akka Team
On Fri, Apr 28, 2017 at 5:54 PM, Richard Rodseth
I tried to reproduce your problem, but I cannot see any problems with the
predicate not being honoured. Here's a gist with what I did to reproduce
it: https://gist.github.com/johanandren/7d01d19211867df0c308ba5fb1294162
--
Johan
Akka Team
On Mon, Apr 24, 2017 at 10:35 AM, Ankit Thakur <an
yet hardened enough to
use.
You can see the settings in reference.conf here:
http://doc.akka.io/docs/akka/2.5.0/general/configuration.html#config-akka-remote-artery
- inbound-lanes and outbound-lanes.
--
Johan
Akka Team
On Fri, Apr 28, 2017 at 12:45 PM, Yaroslav Klymko <t3h...@gmail.com> w
Looks like you are doing the right thing there, consuming the entity before
responding, could it be that the create methods throw an exception perhaps?
That would lead to the request body not being consumed as far as I can see.
--
Johan
Akka Team
On Thu, Feb 16, 2017 at 6:42 AM, Vasiliy Levykin
0.15
In your maven pomfile, if you want to explicitly list Akka as well,
you could then see in your IDE which versions that kaka-stream-kafka pulls
in and add those versions.
--
Johan
Akka Team
On Fri, Apr 28, 2017 at 4:38 PM, Shannon Ma <shanno...@gmail.com> wrote:
> With 2.12, i had
not be
possible to use the latter with mapAsync.
--
Johan
Akka Team
On Sat, Apr 8, 2017 at 1:08 AM, Richard Rodseth <rrods...@gmail.com> wrote:
> I'm still curious what, if any, advantages the ProducerStage as in
> reactive-kafka has over using mapAsync as in CassandraSink. Anyone?
>
>
od as you describe it. I
think you would have devise your own path-like directive to achieve this,
using mapRequestContext and mapRequest would let you modify the request
path and the consumed path.
--
Johan
Akka Team
On Sun, Mar 19, 2017 at 8:55 PM, AL <123...@gmail.com> wrote:
> Hi,
&
the thread pool with the first n actors
that run, and no other actor can run until their sleeps has completed.
--
Johan
Akka Team
On Mon, Mar 27, 2017 at 4:45 AM, <kongunattuara...@gmail.com> wrote:
> Hello,
>
> I am trying to achieve this use case part of my learning e
If you look at the sources of Pool.props(props) all it does is calling
props.withRouter(this), so the two options are pretty much identical so you
can choose whichever you like best.
--
Johan
Akka Team
On Wed, Apr 12, 2017 at 6:27 PM, Tu Pham Phuong <pham...@gmail.com> wrote:
> My s
why there only is SBT+Scala support right now. Adding a Java API
and allowing that to be used with SBT would be easier though.
--
Johan
Akka Team
On Thu, Apr 27, 2017 at 1:10 PM, 'Francesco laTorre' via Akka User List <
akka-user@googlegroups.com> wrote:
> Moreover, a very good op
These two sample projects shows an example of this:
https://github.com/typesafehub/activator-akka-distributed-workers
https://github.com/typesafehub/activator-akka-distributed-workers-java
--
Johan
Akka Team
On Fri, Mar 3, 2017 at 9:52 PM, <learnspr...@gmail.com> wrote:
> How do i crea
-stream-contrib/blob/master/contrib/src/main/scala/akka/stream/contrib/Retry.scala
--
Johan
Akka Team
On Wed, Apr 5, 2017 at 5:15 PM, scallahan via Akka User List <
akka-user@googlegroups.com> wrote:
> Hey all,
>
> In my example below I have a source queue. In the middle I have a
decisions, the sample is just there to show that you would start
from a stored offset and store offset as the query progress.
--
Johan
Akka Team
On Thu, Apr 13, 2017 at 11:30 PM, Richard Rodseth <rrods...@gmail.com>
wrote:
> Congrats on the release of 2.5.
>
> Isn't the documentation a
processEven ~> merge.in(0)
partition.out(1) ~> processOdd ~> merge.in(1)
FlowShape(partition.in, merge.out)
})
--
Johan
Akka Team
On Tue, Mar 21, 2017 at 1:18 PM, Vishal John <vishalj...@gmail.com> wrote:
>
> Hello all,
>
>
> I have defined my applic
--
Johan
Akka Team
On Fri, Mar 24, 2017 at 5:47 AM, Ravikumar Maddi <ravi.ma...@gmail.com>
wrote:
> up vote
> down votefavorite
> <http://stackoverflow.com/questions/42990024/could-not-access-type-loggingadapter-in-value-akka-event#>
>
> I migrated from Scala 2.10.8 to 2.11
I think this question has a higher chance of getting an answer if asked in
the Spark community/mailing list.
The linked project seems to be more about feeding data from Akka Streams
into spark than running Akka Streams inside of Spark.
--
Johan
Akka Team
On Fri, Mar 17, 2017 at 8:49 PM, Kyrylo
) and forward messages to
all currently living web socket actors.
In Akka Streams BroadcastHub will allow you to do something like this
without involving actors directly.
--
Johan
Akka Team
On Sun, Mar 19, 2017 at 1:08 PM, kant kodali <kanth...@gmail.com> wrote:
> Hi All,
>
> I
Hi Dai,
I'm afraid it is currently only possible to run the multi-node tests with
Scala + SBT
--
Johan
Akka Team
On Wed, Mar 22, 2017 at 3:11 AM, Dai Yinhua <yhdai.2...@gmail.com> wrote:
> Anybody knows how to run akka multi node testing in java?
> Is there any
Did you read the docs about the various path directives and how they differ?
http://doc.akka.io/docs/akka-http/10.0.4/scala/http/routing-dsl/directives/path-directives/index.html
--
Johan
Akka Team
On Fri, Mar 17, 2017 at 12:47 PM, Alan Burlison <alan.burli...@gmail.com>
wrote:
> p
improve the wording so it is more clear though, I have
opened a ticket for that: https://github.com/akka/akka/issues/22525
Cheers
--
Johan
Akka Team
On Fri, Mar 10, 2017 at 9:50 AM, Alexandre Delegue <
alexandre.dele...@serli.com> wrote:
> Hi,
>
> should open an issue for th
that works as
expected:
https://gist.github.com/johanandren/35ed29f320ec3a0cece0946fcd70eb89
Cheers
--
Johan
Akka Team
On Tue, Mar 7, 2017 at 6:03 PM, Arkaitz Jimenez <arkaitz.jime...@teamaol.com
> wrote:
> /ClusterAwareActor {
> router = random-group
> routees.
Hi Alan,
I think the sample in the doc section referred to already uses the right
factory method and describes why, but please PR the docs with something
that makes it more clear if you want!
(http://doc.akka.io/docs/akka/current/scala/persistence.html#Failures)
--
Johan
Akka Team
On Wed, Mar 8
, enable debug logging and
maybe it can help you figure it out.
Cheers
--
Johan
Akka Team
On Tue, Feb 28, 2017 at 11:07 AM, Dai Yinhua <yhdai.2...@gmail.com> wrote:
> Hi Akka team,
>
> I am developing an application with cluster sharding.
> And I have below deployment:
> se
,randomFactor:Double):akka.pattern.BackoffOptions
What it says is, do not use this factory method for persistent actors but
instead the Backoff.onStop factory method, not that the back off supervisor
cannot be used with persistent actors.
--
Johan
Akka Team
On Wed, Mar 8, 2017 at 4:00 PM, Alan
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
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!
>
&
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
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
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
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
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.
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.
I'd start with looking at how many elements your MinuteSource emits before
completing in the different cases.
--
Johan
Akka Team
Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM
Twitter: @akkateam
On Wed, Dec 14, 2016 at 11:10 PM, <subo...@gmail.com> wrote:
&
resting:
https://github.com/akka/akka-stream-contrib/issues/50
--
Johan
Akka Team
Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM
Twitter: @akkateam
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>&g
I think it refers to that you could by mistake pass/close over mutable
internal state of the outer actor (ActorContext for example) to the inner
actor which would result in race conditions.
--
Johan
Akka Team
Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM
Twitter: @ak
Akka Team
Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM
Twitter: @akkateam
On Sat, Nov 12, 2016 at 7:22 PM, Shyam kumar Akirala <
a.shyamkum...@gmail.com> wrote:
> 1. Is there any way a node which is part of Cluster can inform other
> members to mark its stat
Hi Adrian,
Maybe Akka Streams would be a better fit for your problem.
You can find the docs here:
http://doc.akka.io/docs/akka/2.4/scala/stream/index.html
--
Johan
Akka Team
Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM
Twitter: @akkateam
On Sat, Nov 26, 2016 at 11
$$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
kka/2.4.14/scala/remoting.html#Remote_Configuration
--
Johan Andrén
Akka Team
On Fri, Dec 2, 2016 at 12:40 AM, Nitin Jadon <nitin.ja...@gmail.com> wrote:
> We are running Akka with Docker image and want to pass all the running
> Akka Docker's IP/Port info in case of addition on new
Source.unfoldAsync could be an existing stage worth looking closer at.
--
Johan Andrén
Akka Team
On Fri, Dec 9, 2016 at 7:31 PM, <subo...@gmail.com> wrote:
> I thought I needed to use a GraphStageLogic because I need to do the
> following:
>
> request url for pag
You can track the ticket to see if there is any progress or contribute such
progress: https://github.com/akka/akka-http/issues/192
--
Johan Andrén
Akka Team
On Fri, Dec 9, 2016 at 4:45 PM, Álvaro Reguly <ubu...@reguly.com> wrote:
> Any news here? This a big deal for us as Akka is lock
Hi Elliot,
look at the directives and custom directives parts of the docs, that should
help you get going:
http://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/directives/index.html
--
Johan
Akka Team
On Thu, Nov 24, 2016 at 1:22 PM, Elliot Laurendeau <tap...@gmail.com>
It's pretty much a question about taste, if you like a PersistentFSM better
than a straight up Persistent Actor, go with it!
An actor that never transitions to a different behaviour would probably be
a bad fit though.
--
Johan
Akka Team
On Mon, Nov 21, 2016 at 1:57 AM, <t.dettr...@uq.edu
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
--
>>>>>
>>>>>> 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
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
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
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
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
/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
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
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
1 - 100 of 782 matches
Mail list logo
