[akka-user] Bootstrapping akka-cluster from etcd - options?

2016-04-26 Thread Val P
Hi, Does anyone have any experience with ConstructR or akka-cluster-etcd for bootstrapping an akka cluster off of etcd? How do the two compare, and are there other options? ConstructR: https://github.com/hseeberger/constructr akka-cluster-etcd: https://github.com/rkrzewski/akka-cluster-etcd

[akka-user] Dstributing data in akka cluster (guidance needed)

2016-04-05 Thread Val P
HI, I am looking for guidance, if anyway is willing to share their experience: I have an akka distributed system where I want to store small amounts of data (basically tombstones and other assorted bits). They may be stored on one node and consumed on another at a later time if the connection

Re: [akka-user] [akka-stream] tcp retransmission?

2016-02-29 Thread Val P
have no access to that low level TCP features. In other words, I really > don't know what is going on on your machine and why you are seeing it, but > I don't think we can do anything about it. > > -Endre > > On Mon, Feb 29, 2016 at 2:08 AM, Val P <injv...@gmail.com > > wro

[akka-user] [akka-stream] tcp retransmission?

2016-02-28 Thread Val P
I am trying to understand why I'm seeing TCP retransmissions on a simple program. I created a small program based on the 2.4.2 docs: object HelloWorld { def main(args: Array[String]): Unit = { implicit val system = ActorSystem("Sys") implicit val materializer = ActorMaterializer()

Re: [akka-user] Re: [akka-stream-2.0.3] how to force terminate a stream?

2016-02-26 Thread Val P
I forgot to mention: in my case, is streams under akka-http. So I have a WebSocket client I need gone. On Friday, February 26, 2016 at 1:18:17 PM UTC-6, Val P wrote: > > Sorry for the confusion. it was more of a comment, not a question. I can't > post code right now (I'm on

Re: [akka-user] Re: [akka-stream-2.0.3] how to force terminate a stream?

2016-02-26 Thread Val P
of more clarification and validation. On Friday, February 26, 2016 at 11:47:46 AM UTC-6, drewhk wrote: > > > On Fri, Feb 26, 2016 at 6:02 PM, Val P <injv...@gmail.com > > wrote: > >> This area kinda needs work, IMHO. However my understanding is very weak, >> so

Re: [akka-user] DistributedPubSub -- list of topics

2016-02-26 Thread Val P
: > > Hi Val, > > > > On Fri, Feb 19, 2016 at 6:28 PM, Val P <injv...@gmail.com > > wrote: > >> Hi All, >> I'm experimenting with the PubSubMediator and Akka Cluster. So far so >> good, but I have one use case which I cannot cover yet. >> >>

[akka-user] Re: [akka-stream-2.0.3] how to force terminate a stream?

2016-02-26 Thread Val P
This area kinda needs work, IMHO. However my understanding is very weak, so please don't take anything I say with much weight. So a completeStage() seems to...er.. complete the stage, but it takes a minute for the connection to be closed, when it finally times out. Setting eagerComplete = true

[akka-user] DistributedPubSub -- list of topics

2016-02-19 Thread Val P
Hi All, I'm experimenting with the PubSubMediator and Akka Cluster. So far so good, but I have one use case which I cannot cover yet. Is it possible to either: a. Use a custom comparer on a Publish operation, to match a Publish request against multiple topics using wildcards? E.g. similar

[akka-user] akka-http - state data

2016-01-24 Thread Val P
I am trying to update a spray sample to work with akka-http, first try. It's not immediately obvious to me how I should associate state data with a client connection in my service. Could someone clarify? I may have missed it in the documentation, so I apologize in advance. What I need to

[akka-user] Re: Unit testing Akka-http low level API

2015-09-24 Thread Val P
y server in beforeAll(), run my test, and end it in afterAll()? On Thursday, September 10, 2015 at 11:30:22 PM UTC-5, Val P wrote: > > Hi, > > Can the akka-http 1.0 low level api be tested using Akka-http-testkit? > So far, It appears only the high level api (using the routing dsl) can be &

[akka-user] Re: Unit testing Akka-http low level API

2015-09-24 Thread Val P
. :) On Thursday, September 10, 2015 at 11:30:22 PM UTC-5, Val P wrote: > > Hi, > > Can the akka-http 1.0 low level api be tested using Akka-http-testkit? > So far, It appears only the high level api (using the routing dsl) can be > tested? > > Could someone be kind enough to

Re: [akka-user] Unit testing Akka-http low level API

2015-09-22 Thread Val P
> Hope this helps! > -- > Cheers, > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Typesafe <http://typesafe.com> > > On 11 September 2015 at 05:20:11, Val P (injv...@gmail.com ) > wrote: > > Hi, > > Can the akka-http 1.0 low level api be teste

[akka-user] Unit testing Akka-http low level API

2015-09-10 Thread Val P
Hi, Can the akka-http 1.0 low level api be tested using Akka-http-testkit? So far, It appears only the high level api (using the routing dsl) can be tested? Could someone be kind enough to point me or show me how to write unit tests for the low level API? -- >> Read the