[akka-user] [akka-streams-1.0-RC4 scala] Questions about completing a stream when using Source.actorRef[...]

Hello, I'm using Source.actorRef[...] for a unknown size but bounded stream (I don't know how many elements but I do know it will end). The high level outline of the stream is below and sample code can be found in this gist . Client1->Act

[akka-user] Re: how do I use the scala repl to inspect a "in java written" actor system.

scala -cp On Monday, June 29, 2015 at 11:58:14 AM UTC+3, john@gmail.com wrote: > > Sorry that I know so little about scala. > I have written a java akka system which uses maven for dependeny > management. > > I would now like to inspect my configuration (Typesafe Config Library >

[akka-user] Clustering joining takes longer since updating to 2.3.11

Hi, We have a 9 node Akka Cluster and we have noticed some behavior changes since we updated from 2.3.9 to 2.3.11. We are seeing nodes getting stuck while trying to JOIN the cluster: 2015-06-29 19:31:58,394 INFO [Main-akka.actor.default-dispatcher-4] - Cluster Node [akka.tcp://Main@node1:2551]

Re: [akka-user] count, process message in Akka

Thanks for your response, I'm new to akka every minute I need to display count of all messages(received, sent & processed), private final val queue = new ConcurrentLinkedQueue[Envelope]() returning null, if I extend the custom mailbox On Monday, June 29, 2015 at 11:23:23 AM UTC-7, √ wrote: >

Re: [akka-user] count, process message in Akka

Hi Samy, What's the use-case? On Mon, Jun 29, 2015 at 8:14 PM, Samy wrote: > How to Query (or get all) messages with a specific sender in a custom > mailbox, I followed Akka custom mailbox but I dont have any luck > > -- > >> Read the docs: http://akka.io/docs/ > >> Check the FA

[akka-user] count, process message in Akka

How to Query (or get all) messages with a specific sender in a custom mailbox, I followed Akka custom mailbox but I dont have any luck -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

[akka-user] Re: Remove, count, read messages in mailbox

Jonathan, Any luck with your above requirement ? On Monday, November 11, 2013 at 2:32:07 PM UTC-8, Jonathan Uptmore wrote: > > I'm evaluating Akka for a specific use case in which I need to be able to > perform the mailbox features below. > > 1. Query (or get all) messages with a specific sender

Re: [akka-user] Abrupt termination after a PUT completed

Thanks! On Monday, June 29, 2015 at 4:38:51 AM UTC-4, drewhk wrote: > > See this ticket: https://github.com/akka/akka/issues/17854 > > We will fix this very soon. > > On Fri, Jun 26, 2015 at 10:51 PM, IR > > wrote: > >> Hi all, >> >> Been trying to resolve an issue with AbruptTerminationException

Re: [akka-user] Re: ANNOUNCE Akka Streams & HTTP 1.0-RC4

My mistake I guess, I thought I saw RC3 when I did the process below. However now it's working as expected. :-) Thanks! Process: google "akka" click top link taking me to "akka.io" click documentation see RC3 instead of RC4 On Mon, Jun 29, 2015 at 7:00 AM, Endre Varga wrote: > > > On Mon, Ju

Re: [akka-user] Re: ANNOUNCE Akka Streams & HTTP 1.0-RC4

On Mon, Jun 29, 2015 at 12:41 PM, Endre Varga wrote: > > > On Sun, Jun 28, 2015 at 2:40 AM, Gary Struthers > wrote: > >> After updating I can't find *akka-http-spray-json-experimental *for >> RC4 and get this error >> >> [error] missing or invalid dependency detected while loading class file >>

Re: [akka-user] Re: ANNOUNCE Akka Streams & HTTP 1.0-RC4

On Sun, Jun 28, 2015 at 2:40 AM, Gary Struthers wrote: > After updating I can't find *akka-http-spray-json-experimental *for > RC4 and get this error > > [error] missing or invalid dependency detected while loading class file > 'SprayJsonSupport.class'. > > [error] Could not access type FlowMater

Re: [akka-user] Re: ANNOUNCE Akka Streams & HTTP 1.0-RC4

Hi Mark, which site are you referring to specifically? As you can see on http://akka.io/docs/ we're linking to RC4. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 29 June 2015 at 12:37:53, Mark van Buskirk (markvanbusk...@gmail.com) wrote: I see the site is now giving the RC3 dependencie

[akka-user] Re: ANNOUNCE Akka Streams & HTTP 1.0-RC4

I see the site is now giving the RC3 dependencies and documentation. Did they pull RC4 back to fix a some bugs? Where can I find news like that? On Saturday, June 27, 2015 at 8:40:46 PM UTC-4, Gary Struthers wrote: > > After updating I can't find *akka-http-spray-json-experimental *for > RC4 a

[akka-user] Cluster startup

Hi I am migrating my cluster to a 3 node setup from two nodes. What i noticed now is that if the first noe starts before the two other nodes have evicted him, he starts a new cluster. Is this because he is the first node in the seed node list? Should i use a different seed node list for normal jo

[akka-user] Modeling simple TCP protocol that isn't always request/response in akka-stream

I'm currently rewriting a library I have that previously used akka IO pipelines. Reading through the examples of streaming IO with akka-stream and akka-http, I've only seen examples with request -> response type protocols. Currently, I have a BidiFlow that serializes/deserializes between ByteS

[akka-user] how do I use the scala repl to inspect a "in java written" actor system.

Sorry that I know so little about scala. I have written a java akka system which uses maven for dependeny management. I would now like to inspect my configuration (Typesafe Config Library ) with a scala repl. This is described in http://doc.akka.io/docs/

Re: [akka-user] Abrupt termination after a PUT completed

See this ticket: https://github.com/akka/akka/issues/17854 We will fix this very soon. On Fri, Jun 26, 2015 at 10:51 PM, IR wrote: > Hi all, > > Been trying to resolve an issue with AbruptTerminationException in > Akka-Http 1.0RC4. > > I am PUTing a file after downloading it. The below code run