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

  •        3

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.

toketi-iothubreact - Akka Stream library for Azure IoT Hub


IoTHub React is an Akka Stream library that can be used to read events from Azure IoT Hub, via a reactive stream with asynchronous back pressure, and to send commands to connected devices. Azure IoT Hub is a service used to connect thousands to millions of devices to the Azure cloud.The library can be used both in Java and Scala, providing a fluent DSL for both programming languages, similarly to the approach used by Akka.

macroid-akka-pingpong - An Activator template featuring Macroid and Akka on Android


This Activator template features Macroid and Akka in a 100%-Scala Android application. It shows how to make user interfaces composable — with Macroid’s tweaks, snails and UI actions, and reactive — by using Akka to interconnect interface fragments.

squbs - Akka/Akka HTTP for Large-Scale Production Deployments


squbs (pronounced "skewbs") is a software container and a suite of components enabling standardization and operationalization of Akka and Akka HTTP applications/services in a large scale, managed, cloud environment. It standardizes how Akka applications are deployed in different environments and how they are hooked up to the operational environments of large, internet-scale organizations.Also check out these slightly more advanced samples.



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.

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.

activator-akka-supervision


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

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.