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

[Brandon Gauthier]

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->ActorRef/Source[Message]->parseFlow[Message, String]->threadSink[
String]->"materialize[Result]"->Client2

My goal is to have the stream be populated via messages to an actor and 
then when the stream is "done" have a way to materialize a result to a 
different part of the application. Input is one client's concern, output is 
another client's concern.

Per the documention 

 for 
 Source.actorRef[...]:  

> The stream can be completed successfully by sending akka.actor.PoisonPill
>  or akka.actor.Status.Success to the actor reference.
>
> The stream can be completed with failure by sending 
> akka.actor.Status.Failure to the actor reference.
>

In both cases it pretty clearly states that akka.actor.Status.Success will 
end the stream with success. However when I send in  Status.Success I get a 
ClassCastException 
from the parseFlow. The parsFlow is expecting a Message but its getting a 
Status.Success. 

I also get ClassCastException for Status.Failure. The PoisonPill stops the 
stream immediately and no results are gathered.

I'm not sure why this exception is being thrown. I'm very new to 
akka-streams so I can't tell if is an issue with my usage or I 
am misinterpreting the documentation. I would appreciate any help.

Exception and program output is below, code is here 
.
 Flow Pre Parse: Message(hello)
 Flow Pre Parse: Message(world)
Flow Post Parse: HELLO
 Flow Pre Parse: Message(this)
Flow Post Parse: WORLD
 Flow Pre Parse: Message(is)
Flow Post Parse: THIS
 Flow Pre Parse: Message(a)
Flow Post Parse: IS
   Sink: HELLO
 Flow Pre Parse: Message(test)
   Sink: HELLO , WORLD
Flow Post Parse: A
   Sink: HELLO , WORLD , THIS
Flow Post Parse: TEST
   Sink: HELLO , WORLD , THIS , IS
   Sink: HELLO , WORLD , THIS , IS , A
   Sink: HELLO , WORLD , THIS , IS , A , TEST
[ERROR] [06/29/2015 16:17:49.101] [default-akka.actor.default-dispatcher-9] 
[akka.dispatch.Dispatcher] akka.actor.Status$Success$ cannot be cast to 
com.example.Test2$Message
java.lang.ClassCastException: akka.actor.Status$Success$ cannot be cast to 
com.example.Test2$Message
at com.example.Test2$$anonfun$3.apply(Test2.scala:39)
at akka.stream.impl.fusing.Map.onPush(Ops.scala:23)
at akka.stream.impl.fusing.Map.onPush(Ops.scala:22)
at 
akka.stream.impl.fusing.OneBoundedInterpreter$$anon$1.run(Interpreter.scala:436)
at 
akka.stream.impl.fusing.OneBoundedInterpreter$State$class.progress(Interpreter.scala:245)
at 
akka.stream.impl.fusing.OneBoundedInterpreter$$anon$1.progress(Interpreter.scala:434)
at 
akka.stream.impl.fusing.OneBoundedInterpreter.akka$stream$impl$fusing$OneBoundedInterpreter$$execute(Interpreter.scala:580)
at 
akka.stream.impl.fusing.OneBoundedInterpreter$State$class.execute(Interpreter.scala:241)
at 
akka.stream.impl.fusing.OneBoundedInterpreter$EntryState.execute(Interpreter.scala:666)
at akka.stream.stage.AbstractStage.enterAndPull(Stage.scala:74)
at 
akka.stream.impl.fusing.ActorOutputBoundary.akka$stream$impl$fusing$ActorOutputBoundary$$tryPutBallIn(ActorInterpreter.scala:217)
at 
akka.stream.impl.fusing.ActorOutputBoundary$$anonfun$downstreamRunning$1.applyOrElse(ActorInterpreter.scala:305)
at 
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.stream.impl.SubReceive.apply(Transfer.scala:16)
at akka.stream.impl.SubReceive.apply(Transfer.scala:12)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
at akka.stream.impl.SubReceive.applyOrElse(Transfer.scala:12)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at akka.actor.Actor$class.aroundReceive(Actor.scala:467)
at 
akka.stream.impl.fusing.ActorInterpreter.aroundReceive(ActorInterpreter.scala:366)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)
at akka.dispatch.Mailbox.run(Mailbox.scala:220)
at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at 
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at 
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

Thanks for your help,
--Brandon

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ:

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

[Adam]

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 
> ) with a scala repl. 
> This is described in 
> http://doc.akka.io/docs/akka/2.3.11/general/configuration.html 
> "Logging of Configuration"
>
>
> How do I import my jar into the scala repl so that I can inspect with the 
> repl my cofig?
>
>
>
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Héctor Veiga]

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] - Node 
[akka.tcp://Main@node2:2551] is JOINING, roles []

It remains in this state until it decides to shutdown since it was not able 
to join the cluster. My cluster does not start since there is a minium 
number of members required.

Was there anything that substantially changed from 2.3.9 to 2.3.11 
regarding the joining logic?

I tried to look for an open bug/ticket in github but couldn't find anything.

Thank you,

Héctor Veiga.

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Samy]

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:
>
> 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 FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >> Search the archives: https://groups.google.com/group/akka-user
>> --- 
>> You received this message because you are subscribed to the Google Groups 
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an 
>> email to akka-user+...@googlegroups.com .
>> To post to this group, send email to akka...@googlegroups.com 
>> .
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> -- 
> Cheers,
> √
>  

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Viktor Klang]

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 FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



-- 
Cheers,
√

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] count, process message in Akka

[Samy]

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
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Samy]

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 in a mailbox
> 2. Read or inspect the state of messages in a mailbox (which have not been 
> processed by the consumer actor)
> 3. Remove or delete messages from a mailbox so the consumer actor does not 
> process the messages
>
> Other desirable but not required features of a mailbox are:
>
> 4. Order messages to be processed by a common attribute of type long. 
>  This attribute controls the sequence.  For example, value of 1 should be 
> processed before value of 3.  I would like this order to apply to all 
> messages in the consumer's mailbox not just messages from a particular 
> sender.  I understand that this could cause starvation or indefinitely keep 
> messages at the end of the sequence.  This is desired behavior.
> 5. Process messages by priority - typical low, medium, high type of 
> priority
> 6. Keep copies of sent messages and mark them as sent - I could possibly 
> use Akka Persistence (aka eventsourced) and these features would be best 
> provided through a mailbox API in my case
> 7. Read and delete sent messages
>
> Assumptions: Assume that each mailbox is a single consumer mailbox and not 
> used with a BalancingDispatcher. No actor can read or change the mailbox of 
> another actor.  An actor may read or change its mailbox while processing a 
> message in its onReceive method.
>
> http://letitcrash.com/post/17707262394/why-no-mailboxsize-in-akka-2 provides 
> some good details that hint at how to implement the features I'm seeking 
> with Akka Extensions and custom mailbox implementations.  Can someone 
> please elaborate on the implementation details to provide the features I 
> need?  It is not clear how to get the mailbox instance or reference from 
> the actor or an extension. I plan to use Akka Java 2.3.
>
> Thanks,
> Jonathan 
>
>
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[IR]

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 in 
>> Akka-Http 1.0RC4.
>>
>> I am PUTing a file after downloading it. The below code runs in an actor 
>> and when the uploadResponse is received, I PoisonPill the actor. Whether I 
>> PoisonPill immediately or with a delay, I receive an 
>> AbruptTerminationException.
>>
>> Do I need to manually close the stream somehow?
>>
>> Http()(context.system).singleRequest(HttpRequest(uri = 
>> source)).flatMap(downloadResponse 
>> => {
>>   downloadResponse.entity match {
>> case e: UniversalEntity => {
>>   val headers = List(RawHeader("systemid", systemId), RawHeader(
>> "correlationid", correlationId), RawHeader("checksum", checksum))
>>   Http()(context.system).singleRequest(HttpRequest(method = 
>> HttpMethods.PUT, uri = destination, entity = e, headers = 
>> headers)).map(uploadResponse 
>> => {
>> context.system.scheduler.scheduleOnce(FiniteDuration(15, 
>> "second"), self, PoisonPill)
>> //self ! PoisonPill
>> "Done"
>>   })
>> }
>> case o => Promise.failed(new RuntimeException(s"FAILURE: 
>> ${o.toString}")).future
>>   }
>> })
>>
>> Thanks,
>> IR
>>
>> -- 
>> >> Read the docs: http://akka.io/docs/
>> >> Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >> Search the archives: https://groups.google.com/group/akka-user
>> --- 
>> You received this message because you are subscribed to the Google Groups 
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an 
>> email to akka-user+...@googlegroups.com .
>> To post to this group, send email to akka...@googlegroups.com 
>> .
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Mark van Buskirk]

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, 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
>>> 'SprayJsonSupport.class'.
>>>
>>> [error] Could not access type FlowMaterializer in package akka.stream,
>>>
>> This has been renamed from FlowMaterializer to Materializer. I suspect a
> version mismatch in your build setup. All artifacts should be the RC4
> artifacts.
>
> -Endre
>
>
>
>> [error] because it (or its dependencies) are missing. Check your build
>>> definition for
>>>
>>> [error] missing or conflicting dependencies. (Re-run with
>>> `-Ylog-classpath` to see the problematic classpath.)
>>>
>>> [error] A full rebuild may help if 'SprayJsonSupport.class' was
>>> compiled against an incompatible version of akka.stream
>>>
>>>
>>> Also, I can't find *akka-http-testkit-experimental* for RC4
>>>
>>
>> It is there:
>> https://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http-spray-json-experimental_2.10%7C1.0-RC4%7Cjar
>>
>> Same for 2.11:
>>
>>
>> https://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http-spray-json-experimental_2.11%7C1.0-RC4%7Cjar
>>
>>
>>> Are these jars coming soon?
>>>
>>>
>>> Gary
>>>
>>> --
>>> >> Read the docs: http://akka.io/docs/
>>> >> Check the FAQ:
>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>> >> Search the archives:
>>> https://groups.google.com/group/akka-user
>>> ---
>>> You received this message because you are subscribed to the Google
>>> Groups "Akka User List" group.
>>> To unsubscribe from this group and stop receiving emails from it, send
>>> an email to akka-user+unsubscr...@googlegroups.com.
>>> To post to this group, send email to akka-user@googlegroups.com.
>>> Visit this group at http://groups.google.com/group/akka-user.
>>> For more options, visit https://groups.google.com/d/optout.
>>>
>>
>>
>  --
> >> Read the docs: http://akka.io/docs/
> >> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to a topic in the
> Google Groups "Akka User List" group.
> To unsubscribe from this topic, visit
> https://groups.google.com/d/topic/akka-user/-GMxTVpZaDM/unsubscribe.
> To unsubscribe from this group and all its topics, send an email to
> akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Endre Varga]

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
>> 'SprayJsonSupport.class'.
>>
>> [error] Could not access type FlowMaterializer in package akka.stream,
>>
> This has been renamed from FlowMaterializer to Materializer. I suspect a
version mismatch in your build setup. All artifacts should be the RC4
artifacts.

-Endre



> [error] because it (or its dependencies) are missing. Check your build
>> definition for
>>
>> [error] missing or conflicting dependencies. (Re-run with
>> `-Ylog-classpath` to see the problematic classpath.)
>>
>> [error] A full rebuild may help if 'SprayJsonSupport.class' was compiled
>> against an incompatible version of akka.stream
>>
>>
>> Also, I can't find *akka-http-testkit-experimental* for RC4
>>
>
> It is there:
> https://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http-spray-json-experimental_2.10%7C1.0-RC4%7Cjar
>
> Same for 2.11:
>
>
> https://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http-spray-json-experimental_2.11%7C1.0-RC4%7Cjar
>
>
>> Are these jars coming soon?
>>
>>
>> Gary
>>
>> --
>> >> Read the docs: http://akka.io/docs/
>> >> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >> Search the archives: https://groups.google.com/group/akka-user
>> ---
>> You received this message because you are subscribed to the Google Groups
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an
>> email to akka-user+unsubscr...@googlegroups.com.
>> To post to this group, send email to akka-user@googlegroups.com.
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Endre Varga]

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 FlowMaterializer in package akka.stream,
>
> [error] because it (or its dependencies) are missing. Check your build
> definition for
>
> [error] missing or conflicting dependencies. (Re-run with
> `-Ylog-classpath` to see the problematic classpath.)
>
> [error] A full rebuild may help if 'SprayJsonSupport.class' was compiled
> against an incompatible version of akka.stream
>
>
> Also, I can't find *akka-http-testkit-experimental* for RC4
>

It is there:
https://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http-spray-json-experimental_2.10%7C1.0-RC4%7Cjar

Same for 2.11:

https://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http-spray-json-experimental_2.11%7C1.0-RC4%7Cjar


> Are these jars coming soon?
>
>
> Gary
>
> --
> >> Read the docs: http://akka.io/docs/
> >> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Konrad Malawski]

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 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 and get 
this error
[error] missing or invalid dependency detected while loading class file 
'SprayJsonSupport.class'.

[error] Could not access type FlowMaterializer in package akka.stream,

[error] because it (or its dependencies) are missing. Check your build 
definition for

[error] missing or conflicting dependencies. (Re-run with `-Ylog-classpath` to 
see the problematic classpath.)

[error] A full rebuild may help if 'SprayJsonSupport.class' was compiled 
against an incompatible version of akka.stream



Also, I can't find akka-http-testkit-experimental for RC4

Are these jars coming soon?



Gary

--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Mark van Buskirk]

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 and get this error
>
> [error] missing or invalid dependency detected while loading class file 
> 'SprayJsonSupport.class'.
>
> [error] Could not access type FlowMaterializer in package akka.stream,
>
> [error] because it (or its dependencies) are missing. Check your build 
> definition for
>
> [error] missing or conflicting dependencies. (Re-run with 
> `-Ylog-classpath` to see the problematic classpath.)
>
> [error] A full rebuild may help if 'SprayJsonSupport.class' was compiled 
> against an incompatible version of akka.stream
>
>
> Also, I can't find *akka-http-testkit-experimental* for RC4
>
> Are these jars coming soon?
>
>
> Gary
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Cluster startup

[Idar Borlaug]

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 joins and initial startup?


-- 
Idar Borlaug

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Chad Selph]

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 
ByteStrings and case classes, but I only know how to make this work in one 
direction (client makes request, server replies to request). In this 
protocol, the server can also initiate requests to the client.

How can I "inject" a message into the BidiFlow that isn't just a response 
to a client request? I understand at a high level the solution is probably 
to make a Graph with another Source pointing to my serializer, but I've had 
a tough time wrapping my head around the graph DSL. If someone could point 
me to an example of something similar, I'd very much appreciate it.

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[john . vieten]

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/akka/2.3.11/general/configuration.html 
"Logging of Configuration"


How do I import my jar into the scala repl so that I can inspect with the 
repl my cofig?



-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

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

[Endre Varga]

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 runs in an actor
> and when the uploadResponse is received, I PoisonPill the actor. Whether I
> PoisonPill immediately or with a delay, I receive an
> AbruptTerminationException.
>
> Do I need to manually close the stream somehow?
>
> Http()(context.system).singleRequest(HttpRequest(uri = 
> source)).flatMap(downloadResponse
> => {
>   downloadResponse.entity match {
> case e: UniversalEntity => {
>   val headers = List(RawHeader("systemid", systemId), RawHeader(
> "correlationid", correlationId), RawHeader("checksum", checksum))
>   Http()(context.system).singleRequest(HttpRequest(method =
> HttpMethods.PUT, uri = destination, entity = e, headers = 
> headers)).map(uploadResponse
> => {
> context.system.scheduler.scheduleOnce(FiniteDuration(15,
> "second"), self, PoisonPill)
> //self ! PoisonPill
> "Done"
>   })
> }
> case o => Promise.failed(new RuntimeException(s"FAILURE:
> ${o.toString}")).future
>   }
> })
>
> Thanks,
> IR
>
> --
> >> Read the docs: http://akka.io/docs/
> >> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.