activator-akka-stream-java8 - Demonstrate Akka streams in Java8

  •        0

Demonstrate Akka streams in Java8.Akka Streams is an implementation of Reactive Streams, which is a standard for asynchronous stream processing with non-blocking backpressure.

https://github.com/typesafehub/activator-akka-stream-java8

Tags
Implementation
License
Platform

   




Related Projects

activator-akka-stream-scala - Demonstrate Akka streams in Scala


Demonstrate Akka streams in Scala.Akka Streams is an implementation of Reactive Streams, which is a standard for asynchronous stream processing with non-blocking backpressure.

activator-akka-cluster-sharding-scala - Activator template for the Akka Cluster Sharding feature


Activator template for the Akka Cluster Sharding feature. See tutorial.

activator-akka-distributed-workers - Typesafe Activator template for distributed workers with Akka cluster


Typesafe Activator template for distributed workers with Akka Cluster.

activator-akka-distributed-workers-java - Typesafe Activator template for distributed workers with Akka cluster in Java


Typesafe Activator template for distributed workers with Akka Cluster in Java.

activator-akka-jmx-example - Example of using JMX with Akka Actors


This is an example of how to integrate JMX into your Akka Actors. Using this method, you can look inside a running Akka application and see exactly what sort of state your actors are in. Thanks to Jamie Allen for the idea in his book, Effective Akka.Exposing state through JMX is easy, as long as you play by the rules: always use an MXBean (which does not require JAR downloads over RMI), always think about thread safety when exposing internal variables, and always create a custom class that provides a view that the MXBean is happy with.

sample-akka-project - Sample Akka project with Akka 2.0.1 , sbt and gen-idea plugin


Sample Akka project with Akka 2.0.1 , sbt and gen-idea plugin

akka-contrib-extra - ConductR Akka contributions


The contents of this project are intended as an incubator for Akka related things that Reactive Runtime has discovered useful in the course of its development. The intent is that these things will ultimately become PRs against the actual akka-contrib project.

activator-akka-java-seed - A minimal seed template for an Akka with Java build


A minimal seed template for an Akka with Java build

activator-akka-scala-seed - A minimal seed template for an Akka with Scala build


A minimal seed template for an Akka with Scala build

atomic-store - Atomic event store for Scala/Akka


Atomic Store is a system for managing persistent streams of atomic events, with strict consistency. It is intended for systems in which only one event can be admitted to a canonical event log at a time, contingent upon past events. It exists to maintain the atomicity of handling of incoming events, but outsources the actual validation logic back to the event originator. In a sense, the idea here is to do as little as possible to meet this goal, but in a way that is as practical as possible.Atomic Store is built on top of Akka Persistence, which is designed to natively support highly scalable distributed systems with relaxed consistency. A distributed system can maximize its scalability by reducing coupling between its components, and synchronization of state changes is one such coupling. The general approach to relaxed consistency is to take compensatory actions to rectify inconsistencies between distributed components, in retrospect. But this is complex, and not desirable in all situations. Atomic Store is designed for situations where strict consistency is more desirable or appropriate than extreme scalability.

akka-js - Implementation of Akka Actors for Scala.js.


This project is not actively being worked on at present. Instead an actively maintained port of Akka to Scala.js is available here: https://github.com/unicredit/akka.js.We highly recommend you have a look at it instead - it features a full Akka core as well as Streams port working in the browser.

activator-akka-supervision


Activator tutorial for Akka getting people started with Supervision and Fault Handling

akka-http-hello-world - Sample Akka HTTP application packaged up in a Docker container


This is a sample Akka HTTP application packaged up in a Docker container. You can use this project as a starting point for your Akka HTTP projects. The project includes the necessary configuration files for dockerizing the app.

kamon-akka - Kamon Akka Integration


Kamon's integration with Akka comes in the form of two modules: kamon-akka and kamon-akka-remote that bring bytecode instrumentation to gather metrics and perform automatic TraceContext propagation on your behalf.The kamon-akka module require you to start your application using the AspectJ Weaver Agent. Kamon will warn you at startup if you failed to do so.

sbt-akka-sample-chat - a sample sbt setup for running the akka-sample-chat


a sample sbt setup for running the akka-sample-chat

kamon-akka-http - A temporary implementation of the Kamon akka-http module.


Kamon Akka Http module provides bytecode instrumentation to gather metrics and perform automatic TraceContext propagation on your behalf, both on the client and server side.Kamon akka-http module is currently available for Scala 2.11 and 2.12.

rabbitmq-akka-sample - sample for assigning tasks from a rabbitmq queue to akka actors


sample for assigning tasks from a rabbitmq queue to akka actors