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

Thanks for the info. I'll see if I can modify the container infrastructure at my company to make that work. If not, I'll be eagerly awaiting the Akka 2.4 release next year. On Monday, November 17, 2014 4:07:20 AM UTC-8, Akka Team wrote: > > > On Sat, Nov 15, 2014 at 9:51 PM, Ryan Tanner > wro

[akka-user] Re: Scala and Java Actors living together in one system.

Just to be clear, these are all *Akka* actors, right? Parts of your post make it sound as if some other Java actor library might be involed. If it's just Akka actors written in Java, there's no problem creating Java actors in Scala and vice-versa. We have a mixed language codebase and that w

[akka-user] Re: System.currentTimeMillis update

So you want to set the akka's scheduler's base/start/`now` time? 在 2014年11月22日星期六UTC+8上午5时57分40秒，Bilal Günay写道： > > Hi, > > i am testing my application but i need to modify actual date. I am using > in whole application my custom now() method instead of > System.currentTimeMillis(), so i can tes

[akka-user] Scala and Java Actors living together in one system.

Hello, I am being asked to leverage pre-existing actors in a Java lib but my codebase is in pure Scala. These pre-existing actors provide some "aspect" functionality like metrics and monitoring although I could implement my own. 1. Has anyone seen systems like this - is this a common design?

Re: [akka-user] System.currentTimeMillis update

Hi Bilal, I'm not sure I understand, Akka's scheduler does not use System.currentTimeMillis. On Fri, Nov 21, 2014 at 10:57 PM, Bilal Günay wrote: > Hi, > > i am testing my application but i need to modify actual date. I am using > in whole application my custom now() method instead of > System.

[akka-user] System.currentTimeMillis update

Hi, i am testing my application but i need to modify actual date. I am using in whole application my custom now() method instead of System.currentTimeMillis(), so i can test more flexible. I am using akka scheduler but while scheduling jobs, System.currentTimeMillis will be used and if i set ti

[akka-user] dependency between tests when using ImplicitSender and forget to consume a response with any of the expect-methods

Hi! I was bitten by some special behaviour when testing my actorSystem with the help of the ImplicitSender trait. I have two testmethods. In each of them, I send a message to an actor wrapped in a TestActorRef. In the first testcase, I don't consume the answer of the actor with one of TestKit'

Re: [akka-user] Use TypedActor or something else

https://github.com/rkuhn/akka/tree/wip-g%C3%A5lbma-step1/akka-typed Again to remind everyone, zero guarantees about that branch and it’s contents, it’s mostly a research thing currently and quite some time away still. — k  On 20 November 2014 at 18:15:01, Владимир Морозов (greenhos...@gmail.com

Re: [akka-user] Re: [akka-streams] Dynamically add route output port

Thanks, we’ll look into it! On 21 November 2014 at 16:35:23, Oscar Broman (oscar.bro...@gmail.com) wrote: Alright, I have created the issue here:  https://github.com/akka/akka/issues/16363 Thank you for the replies. On Sunday, November 16, 2014 1:42:48 AM UTC+1, Oscar Broman wrote: Hello! I've

[akka-user] Re: [akka-streams] Dynamically add route output port

Alright, I have created the issue here: https://github.com/akka/akka/issues/16363 Thank you for the replies. On Sunday, November 16, 2014 1:42:48 AM UTC+1, Oscar Broman wrote: > > Hello! > > I've been messing around with akka-streams lately and ran into some > problems. I'm not sure where to go

Re: [akka-user] Re: [akka-streams] Dynamically add route output port

Hm... I think that by using smart grouping and fanouts you'd be able to achieve this, but feels like we should perhaps think this one over with the team on a larger scale. Would you mind opening a ticket about a groupBy that an element can go into multiple groups

Re: [akka-user] Reactive actor-actor communication

Hey Adam, sorry it took my a while to get to this email - been consuming the "least responded / oldest" email from the list throughout the week, not sure it this worked well or not yet... :-) By the way - isn't dropping demand messages a problem also in the current >> remote-streams implementation

RE: [akka-user] Use TypedActor or something else

Hello, Weren’t method calls originally referred to as messages in SmallTalk? The problem is not message passing, but the complete absence of type safety when doing so. It is quite ironic that it is developed in part by a company called “TypeSafe”. As it is, you can send any object

Re: [akka-user] Re: Akka Persistence and Kryo serialization

Hey guys, I just skimmed it, but it seems Evgeniy's suggestion should help. If you want it to be explicit you'd have to list all messages, including ActorKilledException in the classes section it seems... Let us know if that solved the problem - may be useful for other hakkers! On Fri, Nov 21, 20

[akka-user] Re: Akka Persistence and Kryo serialization

idstrategy = "default" четверг, 20 ноября 2014 г., 18:25:05 UTC+3 пользователь Richard Bowker написал: > > I thought I'd experiment with using akka-kryo serializer to see what > difference it made to performance of persisting an event (defined by a > simple case class) compared to just allowi

Re: [akka-user] actorOf raises StackOverflowError with long valid name

Hello again, pinging this issue to inform you that I've reimplemented the path checking: https://github.com/akka/akka/pull/16352 It's now faster and won't ever blow up. Having that said, please remember that such huge paths put a huge burden on remoting - avoid such long paths like fire. On Wed,

Re: [akka-user] Re: Akka IO going into endless loop

Hi Peter, Sorry I wasn't able to jump in to help in time. Seems like you have it solved though, thanks for sharing your findings / snippet. As for streams we do want to and will provide something that has the feature you're asking for with akka-streams, we just haven't gotten the time yet to do it

Re: [akka-user] Use TypedActor or something else

Hello Vladimir, The typed actors in 2.x are not the best solution and introduce some overhead on invoking them. In general you should accept the fact that the network is message based anyway and it's more powerful to express things as messages (you reason about messages then), instead of hiding the

[akka-user] Re: how to implement the state migration with consistent hashing routing

the only way is to replicate what cluster -sharding does? use a singleton instance to maintain everything? (but that is contrast with the discipline of DHT which is essentially a de-centralized design?) Best, Nan On Friday, November 21, 2014 7:10:42 AM UTC-5, Nan Zhu wrote: > > Hi, all > > I h

[akka-user] how to implement the state migration with consistent hashing routing

Hi, all I have a question about consistent hashing routing in akka in my system, all actors are stateful, specifically: all the actor maintains one or more lists as their state, the message is indexed by a key. The router then forward the message according to the key to one of the actors which

[akka-user] Design question on with akka persistence

I am trying to build a system to manage configuration values with akka-persistence. I would like to view all changes that has happened to a particular value in the configuration. I have the entire configuration as state in a PersistentActor and when someone queries for changes. I create a new P

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

Not quite sure what you are referring to with "basically the feature did not pull it's weight so it was discontinued”? Are you saying that the akka-camel module is orphaned? Not camel, amqp. It was a module long time ago in the 1.x series:  http://doc.akka.io/docs/akka-modules/

Re: [akka-user] Re: Basic HTTP client with Akka HTTP

Something like a akka-http based curl equivalent would be a great asset for testing, and also a good example. However, I am not sure how much the syntax will change from now to 1.0. If you want to play with it, one capability I would like to see is client-side bandwidth limiting (like the --limit-

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

Hi Konrad, Not quite sure what you are referring to with "basically the feature did not pull it's weight so it was discontinued". Are you saying that the akka-camel module is orphaned? If so, could someone update the docs? Thanks On Monday, 17 November 2014 23:25:14 UTC+11, Konrad Malawski wro