of this inter op situation
would be VERY much appreciated! THANKS in advance!
On Monday, September 26, 2016 at 12:07:55 AM UTC-7, Dagny T wrote:
>
> Hi there,
>
> The latest info I have from a prior Akka Team response was that the Akka
> Actor Publisher/Subscriber APIs are
) sides
of the Network connection; otherwise the backpressure mechanism will fail,
I guess.
Thanks!
D
On Wednesday, September 21, 2016 at 11:01:12 AM UTC-7, Dagny T wrote:
>
>
> Just wanted to check with folks if I had the correct implementation for
> how to protect from blowing up
, September 26, 2016 at 12:07:55 AM UTC-7, Dagny T wrote:
>
> Hi there,
>
> The latest info I have from a prior Akka Team response was that the Akka
> Actor Publisher/Subscriber APIs are now deprecated;
> and one should be looking at the Graph DSL instead.
>
> i.e
me kind of MessageBox to the mobile or webapp User
> that they have to slow down their event activity due to system overload.
>
> THANKS in advance!
> D
>
On Wednesday, September 21, 2016 at 11:01:12 AM UTC-7, Dagny T wrote:
>
>
> Just wanted to check with folks if I h
Hi there,
The latest info I have from a prior Akka Team response was that the Akka
Actor Publisher/Subscriber APIs are now deprecated;
and one should be looking at the Graph DSL instead.
i.e. Latest Akka Docs state:
ActorPublisher and ActorSubscriber
cannot be used with remote actors,
Hi Kunal and Johannes,
THANKS for your posts on this -- as I was also wondering how
exception-handling mid-Flow is supposed to work!
Followup questions for you, please:
- Let's say for simplicity that we have only 3 events flowing through a
Streaming Flow with 5 Stages.
- We put a Try block
:01:12 AM UTC-7, Dagny T wrote:
>
>
> Just wanted to check with folks if I had the correct implementation for
> how to protect from blowing up memory when working with Akka Streams.
>
> I've merged a Lightbend Blog post's code, with the latest API changes for
> Akk
I had found a good blog about the basics of the Akka Actor Model; and
everything looked cool.
However, I then started following up to look at the Akka Docs for
information about Best Practices to handle the complexities of distributed
Fault-Tolerance.
At the moment; the options for handling
I had taken code from the Akka Documentation about handling WebSocket
connections server-side with Akka Streams;
and was able to take the essentials of that to connect to a simple
Javascript Client to send data to the Server, augment it on Server, then
echo it back to the Client.
However, I
Just wanted to check with folks if I had the correct implementation for how
to protect from blowing up memory when working with Akka Streams.
I've merged a Lightbend Blog post's code, with the latest API changes for
Akka v2.4.9, and the latest documentation about buffered streams in the
/WebSocketExampleSpec.scala#L110
Now, I just need to read up on the proper Testkit usage for that!
On Wednesday, August 31, 2016 at 1:23:36 PM UTC-7, Dagny T wrote:
>
> Newbie Testing WebSocket on Stream.
>
> Needed to verify I'm following best-practices on the basics for this!
>
> Pleas
/DagnyTagg2013/ScalaReactive/blob/master/newbie/src/main/scala/streams/streamsWebSocket.scala
Could anyone please help me with resource links or any insight for how to
get past this error?
THANKS in advance!
Dagny T
On Wednesday, August 31, 2016 at 1:23:36 PM UTC-7, Dagny T wrote:
>
>
Has anyone tried this successfully yet?
I'm interested in combining the:
* Akka Reactive Streams Async API goodness
* along with the Actor State-Machine goodness
* and the Cassandra Dynamic Partitioning Fault-Tolerant Cluster goodness
I am running into an Architecture understanding issue in
to support a welcoming community for Akka
Newbs! You'll make the World a Better Place with Akka Everywhere! ;0)
Dagny T
On Thursday, September 1, 2016 at 2:43:46 PM UTC-7, Dagny T wrote:
>
>
> I'd like to find reliable and current information for learning this using
> v2.4.9.
>
I'd like to find reliable and current information for learning this using
v2.4.9.
I've posted a reply to someone else's related message; but wanted to call
Forum attention to please help refer us to a useful Blog or GitHub repo on
this topic; AND
using the latest and greatest TestKit tools!
example of exercising
the baseline concurrency test-cases using Akka-Testkit! Will post that
interest so that we both may get help with that answer!
Cheers!
Dagny T
On Tuesday, August 30, 2016 at 4:05:11 PM UTC-7, Carmen Torres López wrote:
>
> Hello,
>
> I'm doing a research about
TYPO! My latest WebSocketServer experiment is ACTUALLY in:
- streamsWebSocket.scala
On Wednesday, August 31, 2016 at 1:23:36 PM UTC-7, Dagny T wrote:
>
> Newbie Testing WebSocket on Stream.
>
> Needed to verify I'm following best-practices on the basics for this!
>
> Pleas
Newbie Testing WebSocket on Stream.
Needed to verify I'm following best-practices on the basics for this!
Please refer to my Repo:
https://github.com/DagnyTagg2013/ScalaReactive/tree/master/newbie
1) Tried initiating Web Socket Connection JS Client: basicWebSockets.js
then handling it on an
version of the Akka
dependencies!
On Tuesday, August 30, 2016 at 4:34:35 PM UTC-7, Dagny T wrote:
>
>
> I'm trying to find the build.sbt dependencies for testing Akka-Scala APIs.
>
> Would anyone be able to tell me the details for a reliable way in general
> to track down c
respective Maven Dependency library.
Would be FABULOUS to find a similar site for Scala/Akka to lookup libraries
needed to Download; and for a specific Scala class name!!
Thanks!
D
On Tuesday, August 30, 2016 at 4:34:35 PM UTC-7, Dagny T wrote:
>
>
> I'm trying to find the build.sbt dep
/akka/tree/v2.4.9/akka-http-tests
Thanks in advance for any help!
Dagny T
On Tuesday, August 30, 2016 at 4:04:30 PM UTC-7, Jason Steenstra-Pickens
wrote:
>
> Hi,
>
> I'm trying to use the Probes in *StreamTestKit* but I have hit a few
> issues, specifically relating to the
I'm trying to find the build.sbt dependencies for testing Akka-Scala APIs.
Would anyone be able to tell me the details for a reliable way in general
to track down corresponding Maven Artifacts for undefined symbols with
Scala and Akka?
Thus far, I've just been copying build.sbts from
ARRR! Answering myself:
Found it here:
https://github.com/akka/akka/blob/v2.4.9/akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/WebSocketDirectivesSpec.scala
On Tuesday, August 30, 2016 at 3:44:58 PM UTC-7, Dagny T wrote:
>
>
> I am trying to run this code here:
I am trying to run this code here:
http://doc.akka.io/docs/akka/2.4.9/scala/http/routing-dsl/websocket-support.html
I've separated out the Test code into a separate Scala Script; and am
having trouble tracking down all of the necessary imports for the Test code!
I'm hoping this code is part of
Thank you, Jim and Patrik for your responses!
Looking into the VersionVector.scala.
Always amazed at what a good source of learning it is to see
well-structured, code-reviewed Open Source(!)
THANKS again!
D
On Thursday, July 28, 2016 at 11:23:46 AM UTC-7, Dagny T wrote:
>
>
Typo on my last comment; meant to say I 'used' the existing Akka Graph DSL.
(Definitely didn't write my own!)
On Friday, July 15, 2016 at 9:03:05 AM UTC-7, Maatary Okouya wrote:
>
> Hi,
>
> given that Longom is not working to Scala anytime soon. I wonder if
> someone could share with some
Hi Maatary,
Just an update that I had got from the Akka Team on my original stab at an
implementation for this using those (apparently outdated) Activator
Templates:
"The tweet publisher is the glue from the eventStream to Akka Streams. As
you say, there are other ways of doing this. For
So, in the context of async messaging systems where you can't predict the
sequencing of incoming messages.
Typically, you have in the message (or event) payload:
- an Originating Entity Unique ID
- then a Version or Sequence ID for each incremental state-change event on
that originating entity
coherent prototype;
please go ahead and ping me!
Cheers!
Dagny T
On Friday, July 15, 2016 at 9:03:05 AM UTC-7, Maatary Okouya wrote:
>
> Hi,
>
> given that Longom is not working to Scala anytime soon. I wonder if
> someone could share with some good content on how build a go
SO, forgot to add question (4) to my "followup on (Reactive) Microservices
Design"
What's the essential Schema design approach for solving the problem of
associating data between Services?
i.e. Between Customer Order Service and Seller Fulfillment Service?
OLD SCHOOL: Foreign Key for Order
Newbie with Akka and Streams here!
I'm set on understanding the fundamentals of the latest Akka Streams API
through standing up a prototype. ;0)
I've looked to the Typesafe Activator Template on Akka Http with Websockets
to do this; and have posted questions on the Disqus comments section;
the 2.0.4. However, I'll try just using v2.4.8 of akka-http-core and
akka-stream and drop the experimental libs. THANKS!
On Monday, July 18, 2016 at 2:16:19 PM UTC-7, Dagny T wrote:
>
>
> 1) On first running this code through an Intellij debugger; I ran into the
> following Akka Htt
THANK YOU to the Akka Team for answering my questions; which I will need to
go through tomorrow.
On Friday, July 15, 2016 at 10:55:55 PM UTC-7, Dagny T wrote:
>
> Hi there! Akka newbie. Trying to learn the latest Akka Http Streams API
> from this:
> http://www.lightbend.com/activa
Trying to find the best code samples to learn how to use the APIs for Akka
Streams for Http and Websockets.
Started with this Typesafe Activator Template:
http://www.lightbend.com/activator/template/akka-http-websocket-reactive-streams
Posting questions to the Disqus comments section for that.
Hello!
Wanted to ask about your considerations for tradeoffs for using Play vs
straight Akka-Http-Stream and Websockets?
Is this the best forum for such a question; or Quora, or elsewhere?
Thanks!
D
On Tuesday, July 5, 2016 at 7:12:03 AM UTC-7, ani...@egnaroinc.com wrote:
>
> I have a chat
Hello! Wanted to as what your considerations were on tradeoffs for going
for the Play approach as opposed to straight Akka-Http-Stream and
Websockets approach? Or, perhaps suggest the best forum to get such info
-- Quora maybe?
On Tuesday, July 5, 2016 at 7:12:03 AM UTC-7,
On Tuesday, July 5, 2016 at 7:12:03 AM UTC-7, ani...@egnaroinc.com wrote:
>
> I have a chat application developed in Akka and Scala using Play framework
> WebSockets.
> I want to make it as an Api based service. For connection , i have used
> the similar block from official documentaton as:
>
On Sunday, July 17, 2016 at 3:58:53 AM UTC-7, Dagny T wrote:
>
>
> SBT dependencies look like they need to be updated for this Activator
> Template:
> http://www.lightbend.com/activator/template/akka-sample-twitter-streaming
>
> 1) akka-http-experimental needs to be upd
ooking at
above is not a reliable source of information!
Thanks again!
On Sunday, July 17, 2016 at 3:58:53 AM UTC-7, Dagny T wrote:
>
>
> SBT dependencies look like they need to be updated for this Activator
> Template:
> http://www.lightbend.com/activator/template/akka-sample-tw
SBT dependencies look like they need to be updated for this Activator
Template:
http://www.lightbend.com/activator/template/akka-sample-twitter-streaming
1) akka-http-experimental needs to be updated to later version containing
this bugfix:
https://github.com/akka/akka/issues/20236
2) The
Hi there! Akka newbie. Trying to learn the latest Akka Http Streams API
from this:
http://www.lightbend.com/activator/template/akka-sample-twitter-streaming ;
I'm running into bizarre behavior with that; and posted my list of
questions and what I've tried in the Disqus comments just under that
Error running akka-http-microservice Activator template Unable to run
example template: akka-http-microservice from the Activator
Project builds, but on running, unable to access URL,
http://localhost:9000/ip/8.8.8.8 getting 'Internal Server Error'
Error on running service: [ERROR]
42 matches
Mail list logo
