[akka-user] Aeron as Akka's transport layer ?

Aeron looks like a very promising transport layer for Akka given that its message based and Layer 4 protocol (same as TCP) https://groups.google.com/forum/#!msg/mechanical-sympathy/fr7moLcsuiI/XsKndzoR6ycJ Would like to know the thought of others ? Thanks -Soumya -- >> Read t

Re: [akka-user] Using akka-stream to build async pipeline

Nice! I will take a look. 在 2014年11月17日星期一UTC-8上午5时22分47秒，Konrad Malawski写道： > > Hi Leon, > akka-streams is *exactly* an "async pipeline for data processing" :-) > As it's currently "pre experimental" we do not yet provide comprehensive > docs - this should change in a matter of weeks though. > I

Re: [akka-user] Akka, Camel & ActiveMQ oneway

Hi Jeroen, Your approach is correct, and it is intended to override routeResponse if you need different behavior, see the docs. /** * Called after a response was received from the endpoint specified by endpointUri. The * response is passed as argument. By default, this method sends the res

[akka-user] ActorPath vs ActorSelection in AtLeastOnceDelivery

I'm wondering why AtLeastOnceDelivery's deliver method uses ActorPath instead of ActorSelection. Under the hood, it creates an ActorSelection from the ActorPath, but I'm unclear as to why it doesn't accept ActorSelection as deliver's parameter. In another post inquiring about the use of ActorPa

Re: [akka-user] Re: Akka persistentChannel does not delete message from Journal upon confirm

Nevermind. I was mistaken. While the upgrade to akka 2.3.5 made the leak less obvious, it still exists. I have submitted a pull request to the example code Manas provided in order to make it more obvious. On Tuesday, 26 August 2014 10:36:27 UTC-4, Michael Overmeyer wrote: > > For what it's worth

[akka-user] Reactive actor-actor communication

Hello, I was looking at AtLeastOnceDelivery and what problems it might have when the destination actor dies or becomes slow. Apart from the obvious out-of-memory which would eventually happen (and which can be solved with a smarter ALOD version which flushes excess data to disk), there's also t

Re: [akka-user] How to filter out unwanted message based on IP Address

what is the mechanism by which the message is being received? is this a message sent via akka remoting, or is this a TCP connection being accepted by akka IO, or a spray HTTP request, or ? if it is a message that was sent via remoting, you can look at the Address of the sender() actor ref. s

Re: [akka-user] Akka Persistence on the Query Side: The Conclusion

Hi Roland, I am still tracking this one. As far as I know the team hasn't gotten back to this work yet. How are Akka Streams looking in support of this effort? Anything I can do to help move this forward? Best, Vaughn On Monday, October 6, 2014 11:32:20 PM UTC-6, rkuhn wrote: > > Hi Vaughn, >

Re: [akka-user] IllegalStateException in akka.dispatch.BatchingExecutor$Batch.run

Thanks for the description Maxim, would you mind opening an issue on our issue tracker using the data you've collected so far (the stacktrace and your descrition here)? Sounds like there may be something on our side we should look deeper into. Thanks in advanc

[akka-user] [akka-streams] ActorPublisher-based Source

Hi everyone! I am trying to create a stream with an ActorPublisher: class SourceActor extends ActorPublisher[List[Int]] { import akka.stream.actor.ActorPublisherMessage.Request var list = List.range(1, 21).grouped(5).toList // for example def receive = { case Request(elems) => while (

Re: [akka-user] Router Like Behavior with Streams

The main use case would be a flexiroute or groupBy with an elastic cluster. Since remoting/clustering is down the road, was just looking for a possible way to use streams with remoting/clustering, other than ActorPublisher/ActorSubscriber. On Mon, Nov 17, 2014 at 5:05 AM, Konrad Malawski wrote:

Re: [akka-user] IllegalStateException in akka.dispatch.BatchingExecutor$Batch.run

Hello! Our application provides REST interface to database storage. User uploads data via HTTP interface, we store it to JDBC and then do some additional logic that processes uploaded data. HTTP interface is implemented via Spray 1.3.2; Akka version 2.3.6 (but I have seen this problem in previo

Re: [akka-user] IllegalStateException in akka.dispatch.BatchingExecutor$Batch.run

Also, could you have your logger output the full stack trace? On Mon, Nov 17, 2014 at 3:02 PM, Konrad 'ktoso' Malawski < konrad.malaw...@typesafe.com> wrote: > Hi Maxim, > We fixed a very similar bug in akka-streams 0.11, but it does not seem > that’s the exact place that your stacktrace is comin

Re: [akka-user] IllegalStateException in akka.dispatch.BatchingExecutor$Batch.run

Hi Maxim, We fixed a very similar bug in akka-streams 0.11, but it does not seem that’s the exact place that your stacktrace is coming from… Here’s the issue we fixed in 0.11 => https://github.com/akka/akka/issues/16263 Would you mind giving more background on what you’ve been using and when this

[akka-user] IllegalStateException in akka.dispatch.BatchingExecutor$Batch.run

Hello! I'm running Akka application that sometimes logs ISE in BatchingExecutor$Batch.run. I can't find any application class in it stack trace, all classes in it are Akka internal. Is it a problem (bug) in application or in Akka? How to find the cause of it? Here it the complete stack trace:

Re: [akka-user] Using akka-stream to build async pipeline

Hi Leon, akka-streams is *exactly* an "async pipeline for data processing" :-) As it's currently "pre experimental" we do not yet provide comprehensive docs - this should change in a matter of weeks though. If you want to get hakking on it ASAP, the best documentation is API comments and our tests

Re: [akka-user] Accessing Future's onComplete Internal variables

You’ll have to block then. Consider using Actors instead if you can. — k  On 17 November 2014 at 13:51:29, Syd Gillani (s.zeeshangill...@gmail.com) wrote: Alright, but I would like to send the result to an API ( a method in an external class). Is there any way for it. Cheers Syd On Monday,

Re: [akka-user] Accessing Future's onComplete Internal variables

Alright, but I would like to send the result to an API ( a method in an external class). Is there any way for it. Cheers Syd On Monday, 17 November 2014 12:35:42 UTC+1, Konrad Malawski wrote: > > Have you looked into our pipeTo pattern? It allows to send the result of a > Future to an Actor,

Re: [akka-user] Re: Akka, Camel and RabbitMQ - Asynchronously acknowledging specific message

Hi guys, to put some team perspective on it - basically the feature did not pull it's weight so it was discontinued. Also, for things like these external integrations, we feel it's better left up to the community as they really use these external libraries and care a lot about them on a daily basis

Re: [akka-user] Re: Akka persistence: Optimistic Locking

Hi Martin, This is all journal dependent - it's up to the journal implementation to decide how to deal with this, where as the default answer should be that "don't do this". Otherwise you'd have to lock and/or coordinate before every write to make sure you're the one writing - this costs a lot. Su

Re: [akka-user] Remoting, NAT, and Containers

On Sat, Nov 15, 2014 at 9:51 PM, Ryan Tanner wrote: > This is what we're doing in production. I'm working on a writeup which I > will hopefully have up in a few weeks (I know I've said that before ;)) That would be a nice read, looking forward to it, Ryan! -- Akka Team Typesafe - The softwa

Re: [akka-user] Router Like Behavior with Streams

Hi Danny, What you describe sounds more like an "stream of streams" scenario (like our groupBy for example) - using it you can create substreams based on some key and then produce to

Re: [akka-user] Accessing Future's onComplete Internal variables

Have you looked into our pipeTo pattern? It allows to send the result of a Future to an Actor, without having to block on the result: import static akka.pattern.Patterns.pipe; final ActorRef alice = ???; final Future future = ???; pipe(future, ec).to(alice); Alice can receive the value and do

Re: [akka-user] Accessing Future's onComplete Internal variables

Thanks Konrad, The issue with the mapping is that I won't be able to send the results to an external class -- that is exactly my case. I need to send the result of the future to an external class which will perform some other computation and so. I knew about the await method, but as It is descr

Re: [akka-user] Accessing Future's onComplete Internal variables

Hi Syd, your code samples are not valid Java (well, the first one could be if testVar would be a field, but that's unsafe instead maybe use `AtomicReference` and `set` it from the completion?). OnComplete has a `void` method so you cannot return from it. Instead of taking things out of the future

[akka-user] Accessing Future's onComplete Internal variables

Hi, I wanted to ask if there is any way to map the internal variables to the external java ones. For instance, for the following method String testVar=null; future.onComplete(new OnComplete(){ public void onComplete(Throwable t, Object result){ testVar=(String) result;

[akka-user] Cluster sharding : changing the persistence store

Hi, Some context We are working on a public accessible web application (openoox.com). At the moment the application run on play 2.3.6 and akka 2.3.6 We have implemented sharding in our application to distribute the load of some user actions throughout our cluster. At the moment cluster shard

[akka-user] Using akka-stream to build async pipeline

Hi, I'm wondering if akka-stream is a good candidate for creating an async pipeline for data processing. Take http request as example, I'd like the request go thru a series of pipeline handlers 1 by 1 asynchronously and finally get a response. More over, I'd like to see it's capable to jump f

[akka-user] Re: How to Monitor akka, improving performance

Hi, I'm doing nothing in the third actor. Once received the message is simple discarded. I'm simply doing a tell on the actor and passing the message through it. One of the major reasons I posted this thread was to help my self understand the Visual VM. I'm not clear what the various dispatcher