Re: [akka-user] Akka HTTP bind exception on Windows

Hi, is Akka HTTP still using Netty? To solve the problem I built a small HTTP server using Netty that just creates a Akka HttpRequest from a Netty HttpRequest. This is a bit of a hack but I needed a quick solution because our customer gets really impatient and I just needed something that works

Re: [akka-user] ANNOUNCE: Akka 2.4.3 released!

Hi, I found these quite useful: https://github.com/akka/akka/blob/master/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowKillSwitchSpec.scala and: https://github.com/akka/akka/blob/master/akka-stream-tests/src/test/java/akka/stream/javadsl/KillSwitchTest.java -Antti On Wednesday, Apri

Re: [akka-user] Akka streams on a cluster workaround : Is it acceptable approach?

Hello Patrik! Thank you for your comment! While the project is at initial stage, I watch it and tested it for a while. It really is cool and I already decided to use reactive-kafka to cover Kafka area of my requirements. But 'on cluster' part still remains unsolved. ;-( Thank you again!!! --

[akka-user] Stream Testkit expectNextType ?

Hi guys, I've been writing some tests for my stream code and have run up against a situation where I would like to have expectNextType. I've implemented this myself with a pimp, but I'm wondering if there's a better way? implicit class ProbeExtension[T](val p: Probe[T]) { def expectNextT

[akka-user] Why should nodes usually not include themselves in seed node list?

Hi, when discovering seed nodes dynamically, why is it important for every node (except for one) to not include itself in the seed node list? How could split brain happen if all nodes have the same list order of all seed nodes? >From what I understand, split-brain can only happen if multiple n

Re: [akka-user] Akka HTTP bind exception on Windows

No problem, glad to help you. -Antti On Thursday, April 7, 2016 at 3:57:09 PM UTC+3, drewhk wrote: > > Oh, you are our savior! I am 99% sure that that is the solution we are > looking after, thanks! > > -Endre > > On Thu, Apr 7, 2016 at 2:35 PM, Antti Nevala > wrote: > >> Hi, >> >> I'm not sure

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

Thanks :) tors 7 apr. 2016 kl. 17:26 skrev Viktor Klang : > https://github.com/akka/akka/issues/20256 > > On Thu, Apr 7, 2016 at 5:18 PM, Patrik Nordwall > wrote: > >> I agree, we have had that conclusion several times, but never fixed it. >> An issue is a good start, please. >> >> tors 7 apr. 2

[akka-user] Re: [akka java 2.4.2] Akka HTTP client oncomplete callback

Thanks Johan! This looks promising, I have to see at what point we're able to upgrade but should be possible soonish. , Johannes On Thursday, April 7, 2016 at 6:37:02 PM UTC+3, Johan Andrén wrote: > > Hi Johannes, > > First I would recommend you to upgrade to the latest Akka Stream, 2.4.3 if >

Re: [akka-user] [akka-streams] Resource pool for use within a flow

Johan, Thanks for your suggestion -- that worked well! This is purely an academic question at this point, but is there some way to (essentially) implement a resource pool using a flow like: Source(Seq(resource1, resource2, resource3)).map(resource => computeWith( resource)) //<== at this point

[akka-user] Re: Akka Persistence: Where do the execution of the Command Goes when it is not simply a state update

Hi Maatary, What you persist should be a domain event and contain all information you need to replay that change, so if you need to fetch data from an external service then it is very likely that the event should contain that data, or the result of a calculation with that data. You do not howev

[akka-user] Re: akka persistence cassandra question

Hi Yan, Messages in the actor mailbox, that is has not yet been processed by the actor, when a persistent actor stops or crashes are lost. To provide stronger guarantees that no message that has been sent from one actor to another is lost you will have to use UntypedPersistentActorWithAtLeastO

[akka-user] Re: [akka java 2.4.2] Akka HTTP client oncomplete callback

Hi Johannes, First I would recommend you to upgrade to the latest Akka Stream, 2.4.3 if possible, it contains many fixes and improvements over the version you seem to be using (OutputStreamSink is a private, internal API nowadays). The corresponding method in the newer versions is StreamConvert

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

https://github.com/akka/akka/issues/20256 On Thu, Apr 7, 2016 at 5:18 PM, Patrik Nordwall wrote: > I agree, we have had that conclusion several times, but never fixed it. An > issue is a good start, please. > > tors 7 apr. 2016 kl. 16:20 skrev Viktor Klang : > >> Hmmm, since that mechanism is co

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

I agree, we have had that conclusion several times, but never fixed it. An issue is a good start, please. tors 7 apr. 2016 kl. 16:20 skrev Viktor Klang : > Hmmm, since that mechanism is completely internal, perhaps we could solve > that discretely and remove that run-all-on-shutdown. > > On Thu,

Re: [akka-user] Akka persistence - errors on the read side

Also, seeing the work in reactive-kafka to allow the following, I wonder if this is making you rethink akka-persistence-query APIs db.loadOffset().foreach { fromOffset => val settings = consumerSettings .withFromOffset(new TopicPartition("topic1", 1), fromOffset) Consumer.plainSource

Re: [akka-user] Akka persistence - errors on the read side

Isn't this section of the docs naïve in the face of possible errors? http://doc.akka.io/docs/akka/current/scala/persistence-query.html#Materialize_view_to_Reactive_Streams_compatible_datastore Later on that page is an incomplete example of a resumable projection. Won't something like that need to

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

Hmmm, since that mechanism is completely internal, perhaps we could solve that discretely and remove that run-all-on-shutdown. On Thu, Apr 7, 2016 at 4:17 PM, Patrik Nordwall wrote: > > > On Thu, Apr 7, 2016 at 12:46 PM, Viktor Klang > wrote: > >> That is surprising, indeed. >> What was the cau

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

On Thu, Apr 7, 2016 at 12:46 PM, Viktor Klang wrote: > That is surprising, indeed. > What was the cause for that, again? > The original reason is for shutting down the dispatchers, I think. > > On Thu, Apr 7, 2016 at 12:39 PM, Patrik Nordwall < > patrik.nordw...@gmail.com> wrote: > >> One gotc

Re: [akka-user] Akka HTTP bind exception on Windows

if (isWindows) selector.select(1) // :( On Thu, Apr 7, 2016 at 2:57 PM, Endre Varga wrote: > Oh, you are our savior! I am 99% sure that that is the solution we are > looking after, thanks! > > -Endre > > On Thu, Apr 7, 2016 at 2:35 PM, Antti Nevala wrote: > >> Hi, >> >> I'm not sure if this is

Re: [akka-user] Akka HTTP bind exception on Windows

Oh, you are our savior! I am 99% sure that that is the solution we are looking after, thanks! -Endre On Thu, Apr 7, 2016 at 2:35 PM, Antti Nevala wrote: > Hi, > > I'm not sure if this is related but found similar problem from another > project and workaround how to solve it: > > https://github.

Re: [akka-user] Akka HTTP bind exception on Windows

Hi, I'm not sure if this is related but found similar problem from another project and workaround how to solve it: https://github.com/kaazing/nuklei/issues/20 -Antti On Thursday, April 7, 2016 at 11:07:03 AM UTC+3, drewhk wrote: > > Hi, > > > On Tue, Apr 5, 2016 at 8:40 PM, Michi > wrote: > >

Re: [akka-user] Slf4j Akka adapter

Hi Pedro, I looked at your library. I think this can be a good to include in akka-slf4j . Feel free to open a pull request. Thanks, Patrik On Thu, Mar 31, 2016 at 10:08 AM, Konrad Malawski wrote: > One thing to note though is that akka-acto

[akka-user] Re: Cluster sharding monitoring

Hi, There are some APIs for inspecting the cluster sharding state that may be useful for you (mentioned here: http://doc.akka.io/docs/akka/2.4.3/scala/cluster-sharding.html#Inspecting_cluster_sharding_state) which would allow you to create your own monitoring solution or hook into some third

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

That is surprising, indeed. What was the cause for that, again? On Thu, Apr 7, 2016 at 12:39 PM, Patrik Nordwall wrote: > One gotcha with shutting down the actor system is that scheduled tasks > will run (immediately) when the scheduler is shutdown. > > /Patrik > > tors 7 apr. 2016 kl. 12:14 skr

Re: [akka-user] Distributed Data and Akka Cluster Sharding

Ok, so if I do remember-entities as off, then they won't auto start on failover. I might be ok with this. Thanks On Thursday, April 7, 2016 at 6:40:24 AM UTC-4, Kealan Murphy wrote: > > Sorry I quoted too much.. The part about remember-entities being off if > you want to remove akka persistenc

Re: [akka-user] Akka streams on a cluster workaround : Is it acceptable approach?

You might find https://github.com/akka/reactive-kafka interesting /Patrik tors 7 apr. 2016 kl. 09:11 skrev JongHyok Lee : > Hello, > > I'm trying to make dynamic data stream processing engine which can > > - read data from multiple topics on multiple Kafka cluster > - apply several steps of da

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

One gotcha with shutting down the actor system is that scheduled tasks will run (immediately) when the scheduler is shutdown. /Patrik tors 7 apr. 2016 kl. 12:14 skrev Viktor Klang : > Or rather, if scheduled events are not cancelled hen they are no longer > needed, it will be a memory leak. Memo

Re: [akka-user] Distributed Data and Akka Cluster Sharding

Sorry I quoted too much.. The part about remember-entities being off if you want to remove akka persistence would hint that ddata is not yet covering that use case. On Thursday, 7 April 2016 11:18:56 UTC+1, Paul Cleary wrote: > > I do have this dependency in my build... > > "com.typesafe.akka"

Re: [akka-user] Distributed Data and Akka Cluster Sharding

I do have this dependency in my build... "com.typesafe.akka" %% "akka-distributed-data-experimental" % akkaV, On Thursday, April 7, 2016 at 6:16:40 AM UTC-4, Kealan Murphy wrote: > > From here > > >

Re: [akka-user] Distributed Data and Akka Cluster Sharding

>From here "You must explicitly add the akka-distributed-data-experimental dependency to your build if you use this mode. It is possible to remove akka-persistence dependency from a project if it is not used

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

Or rather, if scheduled events are not cancelled hen they are no longer needed, it will be a memory leak. Memory leaks are bad no matter if you shut the actor system down or not :) But to answer the question: shutting down the ActorSystem shuts down the Scheduler. On Thu, Apr 7, 2016 at 12:11 PM,

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

Yes, although that's a bit like asking "can I stop a car by driving it into a tree?" :-) In general you should cancel scheduled events (schedule() returns a cancellable), instead --  Cheers, Konrad 'ktoso’ Malawski Akka @ Lightbend On 7 April 2016 at 12:09:59, Kayode Odeyemi (drey...@gmail.com

[akka-user] Cancel a Scheduler by terminating its ActorSystem

Can I cancel a Scheduler by terminating its ActorSystem? -- >> 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] Distributed Data and Akka Cluster Sharding

Here is the config I am using... I am using the dynamodb akka persistence plugin right now and it works fine when it is in there. If I take out the persistence configuration all together then cluster sharding does not start up, I see this error: 16-04-07 01:06:14,514 [test] ERROR | [project-a

Re: [akka-user] Dedicated seed nodes for akka cluster

There is Consul support for ConstructR, for details please join the ConstructR channel on Gitter. ConstructR is for bootstrapping an Akka cluster, not for dealing with downing of unreachable nodes. Well, it could help with that as a side-effect, because by default if a node can’t refresh becaus

Re: [akka-user] Distributed Data and Akka Cluster Sharding

Have you **configured** Cluster Sharding to use Distributed Data? Could you paste your configuration? Cheers Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger

Re: [akka-user] Akka HTTP bind exception on Windows

Hi, On Tue, Apr 5, 2016 at 8:40 PM, Michi wrote: > Hi, > > I think SO_REUSEADDR is enabled by default for Akka HTTP. At least it > looks like that when I looked at the code. But even if it is disabled, the > OS should not need ten minutes to release the socket. Maybe I write a > simple test pr

[akka-user] Akka streams on a cluster workaround : Is it acceptable approach?

Hello, I'm trying to make dynamic data stream processing engine which can - read data from multiple topics on multiple Kafka cluster - apply several steps of data processing logic on data stream (like filtering, transformation of data, join, etc) - one data source / processing logic can be sh