a-user/OisR-nYVJXA/unsubscribe.
>> To unsubscribe from this group and all its topics, 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-
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 akka-user+unsubscr...@
ser
> ---
> 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
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@googlegroups.com.
> Visit
;>> --
>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>> >>>>>>>>>> Check the FAQ:
>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>> >>>>>>>>>> S
nsubscribe 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 more options, visit https
;>>>>>> 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
Best regards
> Simon
>
>
>
>
>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>>>> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >>>>>>>>&
.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.
>
--
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter:
;>>>>>>>>> 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,
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
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>
ribed 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 group at https:
;
>> Read the docs: http://akka.io/docs/
>>>>>>>>>>> Check the FAQ:
>>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>>> Search the archives:
>>&
>
> //List response=
> inputData.parallelStream().map(process);
> List response=
> inputData.stream().map(process);
>
> getSender().tell(respose,getSelf());
>
>
> } else unhandled(message);
>
> }
>
>
>
>
> On Thursda
t;>> 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
t more data and get
> then ack (from previous window which was identical). The scenario with the
> protocol is complex so based on what you wrote hopefully I've just
> misread the result I had. We'll see. :)
>
> Regards
> Magnus
>
> tors 12 maj 2016 kl 20:26 skrev Akka T
amer:jsonassert:jar:1.2.3:test
> [INFO] | | \- org.json:json:jar:20090211:test
> [INFO] | +- net.sf.jopt-simple:jopt-simple:jar:4.9:test
> [INFO] | +- xmlunit:xmlunit:jar:1.6:test
> [INFO] | \- com.jayway.jsonpath:json-path:jar:0.8.1:test
> [INFO] | +- net.minidev:json-smart:jar:1.
up.
> 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 more options
kka.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 unsubscribe
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 more options, visit https://groups.google.com/d/optout.
>
er+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.
>
--
Akka Team
Typesafe - Reactive apps on the JVM
B
We use Scalatest, but Specs2 should work fine as well. There is most likely
something special in your project setup or tests.
For example it could be that you run the tests non-forked and keep a
reference to the DefaultLoggingFilter in an object that lives across test
runs.
--
Johan
On Sun, May
This seems to be an oversight in the API, please file a ticket (and if
possible a PR) about it. The materialized type should be Any (Object seen
from the Java side) as it is not really passed on anywhere or consumed by
anything.
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog
terminate the actor system
until that has completed.
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>
That error is thrown if you try to create actors in a terminated actor
system, probably because you are somehow re-using the original actor system
after it has terminated.
--
Johan
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.
Hi Adam,
It seems to be a regression in our build/release scripts, thanks for
notifying us about it, we'll look into it.
(Ticket if you want to follow what is going on:
https://github.com/akka/akka/issues/20661)
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcras
-usage.html#Router_with_Group_of_Routees
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>
constructor of the actor:
receive(emptyBehavior());
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
kka.io/docs/akka/2.4.6/scala/stream/stream-customize.html
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FA
300ms PUT:ing a 10mb file using curl,
and not a significant difference between chunked and non-chunked.
Can you please give us more details about what you are doing seeing these
numbers, what Akka HTTP version, what client you are using, anything else
that may be special etc?
--
Johan
Akka Team
Typ
be to change into a new receive block (using
context.become)
that does not persist any message and keeps track of if it has gotten both
confirmations
yet, and then stops itself.
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>>>>>
bit and I'm sure we will be
able to help you out.
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>>
Hi Regu,
So you mean that with a single node cluster but without kamon the actor is
created by the
pool but if you add kamon it stops working?
Sounds suspiciously much like you have the allow-local-routees setting of
the router set to off,
could this be it?
--
Johan
Akka Team
Typesafe
luster has reached a state with no unreachable nodes the re-joining node
should transition
to the Up state.
You can read more about this in the docs here:
http://doc.akka.io/docs/akka/2.4.6/common/cluster.html#Gossip_Convergence
--
Johan
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.c
called. I would hate to think that that
> is it but even if it was I still need the real root cause and not just the
> why or at least a work-around to handle it.
>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>&g
ups.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.
>
--
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akka
ail 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.
>
--
Akka Team
Typesafe - Reactive apps
ps.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.
>
--
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akk
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.
>
--
Akka Team
Types
gt; So, the situation is, after the IP changed, the reconnected client will
> receive connection closed message very soon (about 1 minute), compare to a
> few minutes in normal connecting, and the darkwebsocket terminal will
> receive two connection closed message. Now I still don't k
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.
>
--
Akka Team
Ty
t;
>>
>> Its connect well but not keep connected :( . Can anyone help me on that ?
>>
>> Thanks!
>>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>>>> Check the FAQ:
>
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 unsubscr
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 that None is instantiated
>>
;
>
>
>
> --
>
> Patrik Nordwall
> Akka Tech Lead
> Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM
> Twitter: @patriknw
>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>&
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 cassanda [user] events
>
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 akka.patterns.ask / pip
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 and while I didn't s
FYI: we will work on performance (of the materialization among other
things) the coming weeks.
Until that is done you probably won't see much difference with anything you
can do about materialization except disabling autoFusing entirely (with
ActorMaterializerSettings), but then you will get a muc
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 ca
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
wrote:
> Hi, as the title says
human 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
Tw
It's unclear to me what you are describing/asking here, could you elaborate?
If you send a message from a non actor the sender will be dead letter as
there is no actual actor to reply to.
Calling a function from the receive block doesn't require that function to
be in the same class (or file), ju
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 thread pool of request
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 wil
MergePreferred will not complete until all its ports has completed. You can
make it complete "eagerly" - as soon as one of the inputs complete like
this:
MergePreferred[Int](1, eagerComplete = true))
--
Johan
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
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 Wed
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 ma
The prior one that is, the adapter as a parameter sounds right.
--
Johan
On Thu, Jul 14, 2016 at 4:57 PM, Viktor Klang
wrote:
> but I'd recommend against that solution since it wouldn't necessarily be
> portable across materializer impls.
>
> --
> Cheers,
> √
&g
ual
> 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 be possible if the hosts resolve to diffe
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.
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: Flow[Something,
ses 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
>> addresses and tho
Thread.sleep(1000);
>
> }
> });
> setHandler(out, new AbstractOutHandler() {
>
> @Override
> public void onPull() throws Exception {
> pull(in);
>
&g
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 using akka, to spur new a
/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 Use
om 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.
>
--
Akk
t;>>>>>>>>> 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
ist" 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/a
akka.io/docs/
> >>>>>>>>>> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message bec
t;>>>>>>>>> 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
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-us
cs/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 unsubscribe from th
st 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
Twitter: @akkateam
--
>
://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 akka-user+unsubscr...@googlegroups.com.
> To pos
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
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 this group, send emai
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 C
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:
> Hello,
>
> I was wondering what is t
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.
M
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 st
t; 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 Google Groups
> "Akka User Li
rns 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" wrote:
>
>> Hi James
>>
>> On Thu, Jul 14, 2016 at 1:22 PM, James Matlik
>> wrote:
>>
>>>
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 a
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 er
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?
--
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
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. N
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 difference
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
expressible
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 h
sed 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:
>>
>> Hi Maatary,
>>
>>
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 arc
be
able to confirm is not in your shade output jar.
--
Johan
Akka Team
On Sat, Aug 6, 2016 at 9:36 PM, Dean Schulze
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 version of ak
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
wrote:
> Hi,
>
> I need origin IP address in my request handler, but I don't know how to
> add this parameter ...
>
> Code is here
>
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
wrote:
> I did a copy and paste from the documentation page for the
> maven-shade-plugin.
#x27;d say it's definitely worth learning ;)
--
Johan
Akka Team
On Tue, Aug 9, 2016 at 6:43 PM, Rob Crawford 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 wrote:
>>
&g
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
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
. 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 wrote:
> Hi guys,
>
> I don't have any seed nodes statically configured. When the cluster
> starts, it consults the
701 - 800 of 955 matches
Mail list logo
