Akka でステートマシンを処理

前回の有限ステートマシン（FSM）の処理を Akka の Java 用 API を使って実装してみます。 Akka 2.5.6 ソースは http://github.com/fits/try_samples/tree/master/blog/20171016/ ステートマシンの実装まずは、以下のステートマシンを実装します。初期状…

2017-09-25

Akka Streams で MQTT Broker へ接続

Java Groovy Akka

ローカルで実行した MQTT Broker（前回参照）に対して Akka Streams の Java 用 API を使って Groovy で接続してみます。 Akka Streams 用の様々なコネクタを備えた Alpakka に MQTT Broker 用の Source や Sink が用意されているので、今回はこちらを使い…

2017-01-31

Akka の FileIO でファイルを読み書き

Akka Java Scala

Akka （akka-stream）の FileIO を使ってファイルの読み書きを行ってみます。 Akka 2.5-M1 今回のソースは http://github.com/fits/try_samples/tree/master/blog/20170131/ はじめに akka-stream では Java 用の API は akka.stream.javadsl パッケージに…