Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

Hi Michal, I'm interested in why you rolled your own RS implementation: was it because you didn't want a dependency on akka, or because akka-streams isn't stable enough yet, or for some other reason? If there was a different library, smaller/more lightweight than akka actors, that provided a

Re: [akka-user] Akka remote - one sender's messages missing

Hi, You can try the configuration settings akka.remote.log-received-messages and akka.remote.log-sent-messages (see: http://doc.akka.io/docs/akka/2.3.6/general/configuration.html#akka-remote) which will then log all sent and received messages at DEBUG level. That information can help you to see

Re: [akka-user] Scalling akka with some caching data

Hi, On Tue, Oct 28, 2014 at 7:09 PM, Maciej Bąk maciej.bak...@gmail.com wrote: Hi, Im doing now solution using akka and websockets from Play framework. I have socketactor, in this actor I have case class UserChannel(userId: String, var channelsCount: Int, enumerator: Enumerator[JsValue],

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

Hi Daniel, I'm interested in why you rolled your own RS implementation: was it because you didn't want a dependency on akka, or because akka-streams isn't stable enough yet, or for some other reason? I feel that this is an apple to oranges kind of comparison. To give you a very imperfect

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

What Endre says is correct and answers part of the question, but an interesting piece remains: would there be value in providing utilities (i.e. abstract base classes) for implementations of the RS interfaces? This can only be answered from experience gained with different such efforts, and I,

Re: [akka-user] Problem with ActorRef when performing Akka persistence for json deserialisation

Hi John, The main problem with serializing ActorRefs directly is that they contain a unique identifier that identifies a current inhabitant of the corresponding actor path (see http://doc.akka.io/docs/akka/2.3.6/scala/actors.html#Actor_Lifecycle). Once the system is restarted and starts to replay

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

On Wed, Oct 29, 2014 at 11:17 AM, Roland Kuhn goo...@rkuhn.info wrote: What Endre says is correct and answers part of the question, but an interesting piece remains: would there be value in providing utilities (i.e. abstract base classes) for implementations of the RS interfaces? Currently

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

Hi Endre, In your two-part analysis, I was referring to the first part, not the second one. I'm wondering why Michał implemented Publishers from scratch, how hard it was in practice, and what kind of library would help with that (if any help was needed). This library need not be akka-streams,

[akka-user] Re: Scalling akka with some caching data

Nevermind Im using play Cache API for it ;) W dniu wtorek, 28 października 2014 19:09:12 UTC+1 użytkownik Maciej Bąk napisał: Hi, Im doing now solution using akka and websockets from Play framework. I have socketactor, in this actor I have case class UserChannel(userId: String, var

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

Hi Daniel, In your two-part analysis, I was referring to the first part, not the second one. I'm wondering why Michał implemented Publishers from scratch, how hard it was in practice, and what kind of library would help with that (if any help was needed). I would also be interested in

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

Hi Daniel, I made my anwser below. Your opinion is valuable for me and I would like you get code review from you. Best Regards, MK 2014-10-29 10:18 GMT+01:00 Daniel Armak: Hi Michal, I'm interested in why you rolled your own RS implementation: was it because you didn't want a dependency on

Re: [akka-user] akka system shut down with no error in logs

On Monday, October 27, 2014, Akka Team akka.offic...@gmail.com wrote: Hi Oren, On Mon, Oct 27, 2014 at 7:22 AM, Oren Razon orenra...@gmail.com javascript:_e(%7B%7D,'cvml','orenra...@gmail.com'); wrote: Hi, I'm using akka 2.3.6 on a single node on Amazon m1.large instance. I'm using akka

[akka-user] Recomended cassandra and mongodb partners

Hello In my company we have plans to use akka-persistence. We need high scalability and high availability, so that we plan to want to use cassandra or mongo db. The people that are already using akka-persistence with any of this two dbs can recommend us any partner that offer commercial

Re: [akka-user] Reactive Streams driver for RabbitMQ #AMQP

Hi Michał, If there was a sufficiently simple / lightweight RS implementation, you could have used that and still provided a library that everyone could use (akka streams, Rx, etc). I don't think you, and everyone else who wants to publish an RS compatible library, should have to (or would enjoy)

[akka-user] Can Akka run without listening on a port?

Hi Folks, We have an application that needs to run in an environment where it is not allowed to listen on any new sockets. It can connect to remote servers, but it can't be a server itself. Is there any way to use Akka in that kind of environment to talk to an Akka service on another machine?

[akka-user] Stopping a reactive stream

Hello, is there a way to stop a reactive running reactive stream, e.g. by making it watch some other actors, and when they are dead, die as well? This might or might not be associated with the components of the stream itself; in my current scenario I have a sink which is a reactive tcp