
### jCenter 側にリポジトリを準備する

jCenter 側にリポジトリを準備する手順は

[jCenterでライブラリを公開する方法 - Qiita](https://qiita.com/ryo_mm2d/items/da49cc4677847c20c3fb "https://qiita.com/ryo_mm2d/items/da49cc4677847c20c3fb")

通りにやれば特に問題ない

ただし、上記の例だと gradle からのアップロードが android ライブラリのパターンになっているため少々分かりづらい  
pure な java ライブラリを公開しようとした場合は若干手順が違うのでまとめる

### pure な java ライブラリを公開する

実際に公開しているライブラリの例

[o-hayato/CombinatoricsUtil](https://github.com/o-hayato/CombinatoricsUtil "https://github.com/o-hayato/CombinatoricsUtil")

ライブラリを公開するために gradle の設定に追加したのは

[:+1: publish to jcenter · o-hayato/CombinatoricsUtil@e704bb6](https://github.com/o-hayato/CombinatoricsUtil/commit/e704bb699a52cd019b59da09508a92390fee66dd "https://github.com/o-hayato/CombinatoricsUtil/commit/e704bb699a52cd019b59da09508a92390fee66dd")

のコミットの変更部分  
上記のような変更を追加すれば、最低限jCeterへアップロードすることが可能になる。

一部普通ではない設定をしてるのでそこだけ紹介する
```
bintray {  
    pkg {  
        version {  
            name = project.version  
        }  
    }  
}
```


`project.version` を使っているのはバージョニングに

[amkay/gradle-gitflow](https://github.com/amkay/gradle-gitflow "https://github.com/amkay/gradle-gitflow") を利用しているからである

Gradle を使って jCenter に java ライブラリ を公開する


## TL;DR

* 正規表現チェックだけではダメ
* IPアドレスは2進数で扱える
* IPアドレス と サブネットマスクを `OR` した結果が サブネットマスクと同一なら問題ない

## やりたいこと

`IPアドレス/ciderBlock` 形式で与えられて文字列のIPアドレス部分がネットワークアドレスを表しているかチェックしたい
簡単にいうと↓こうなってほしい

* OK： 192.0.2.0/24 
* NG： 192.0.2.1/24 


## 解決方法

前提：正規表現等でチェックできる部分はチェック完了している
IPアドレスは2進数として扱えるので以下のようにチェックできる

### OKになる例： 192.0.2.0/24 をチェックする

1. IPアドレス と ciderBlock に分解する
    - ipAddress: 192.0.2.0 
    - ciderBlock:24
1. ciderBlock をサブネットマスクに変換する
    - ciderBlock: 24 -> subnetMask:255.255.255.0
1. IPアドレス・サブネットマスクを2進数で表してORを取る
    - OR を とった結果が サブネットマスクと同一なのでネットワークアドレスを表している

```
ip          : 11000000.00000000.00000010.00000000
subnet      : 11111111.11111111.11111111.00000000
ip OR subnet: 11111111.11111111.11111111.00000000
```

### NGになる例： 192.0.2.1/24 をチェックする

1. IPアドレス と ciderBlock に分解する
    - ipAddress: 192.0.2.1
    - ciderBlock:24
1. ciderBlock をサブネットマスクに変換する
    - ciderBlock: 24 -> subnetMask:255.255.255.0
1. IPアドレス・サブネットマスクを2進数で表してORを取る
    - OR を とった結果が サブネットマスクと異なるのでネットワークアドレスを表していない

```
ip          : 11000000.00000000.00000010.00000001
subnet      : 11111111.11111111.11111111.00000000
ip OR subnet: 11111111.11111111.11111111.00000001
```

## コード

```java
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;

public class Main {

        public static void main(String[] args) throws Exception {

                // "192.0.2.0/24" のような形式を受け取ったとする
                String cidr = args[0];

                // IP とCIDRブロック に分離
                String ipAddress = cidr.split("/")[0];
                String ciderBlock = cidr.split("/")[1];
                System.out.println("ipAddress: " + ipAddress + " ciderBlock:" + ciderBlock);

                // CIDRブロックをサブネットマスクに変換
                // サブネットマスクを数値に変換
                long subnetMaskLong = getSubnetMask(ciderBlock);
                String subnetMask = long2IpAddress(subnetMaskLong);
                System.out.println("ciderBlock: " + ciderBlock + " -> subnetMask:" + subnetMask );
                System.out.println("subnetMask: " + subnetMask + " subnetMask(long):" + subnetMaskLong);

                // IpAddress を数値に変換
                long ipAddressLong = ipAddress2Long(ipAddress);
                System.out.println("ipAddress : " + ipAddress + " ipAddress(long):" +  ipAddressLong);

                // IP と サブネットマスク のORを取ってサブネットマスクが正しいか判定
                long ipAddressOrSubnetMask =  (subnetMaskLong | ipAddressLong);
                System.out.println("ip          : " +  long2BinaryIpAddress(ipAddressLong));
                System.out.println("subnet      : " +  long2BinaryIpAddress(subnetMaskLong));
                System.out.println("ip OR subnet: " + long2BinaryIpAddress(ipAddressOrSubnetMask));

                if (ipAddressOrSubnetMask == subnetMaskLong){
                        System.out.println("SUCCESS");
                }else{
                        System.out.println("!! ERROR !!");
                }

        }

        /**
         *  cidrBlock から サブネットマスクを特定する
         * @param cidrBlock 1~32
         * @return サブネットマスク
         */
        private static long getSubnetMask(String cidrBlock){
                return getSubnetMask(Integer.parseInt(cidrBlock));
        }

        /**
         *  cidrBlock から サブネットマスクを特定する
         * @param cidrBlock 1~32
         * @return サブネットマスク
         */
        private static long getSubnetMask(int cidrBlock){
                long bit1       = 0b0000_0000_0000_0000_0001;
                long subnetMask = 0b0000_0000_0000_0000_0000;
                int bitCount = 32;
                for (int i = cidrBlock; i > 0; i--) {
                        subnetMask |= (bit1 << bitCount-1);
                        bitCount--;
                }
                return subnetMask;
        }

        /**
         * long -> IpAddress
         * @param val 2進数 IpAddress （long）
         * @return IpAddress （文字列）
         */
        private static String long2IpAddress(long val){
                String longVal = Long.toBinaryString(val);
                List<String> eightCharacterDelimitedList = eightCharacterDelimited(longVal);

                return eightCharacterDelimitedList.stream()
                        .map(x -> Integer.parseInt(x,2))
                        .map(x -> Integer.toString(x))
                        .collect(Collectors.joining("."));
        }

        /**
         * long -> IpAddress
         * @param val 2進数 IpAddress （long）
         * @return 2進数 IpAddress （文字列）
         */
        private static String long2BinaryIpAddress(long val){
                String longVal = Long.toBinaryString(val);
                List<String> eightCharacterDelimitedList = eightCharacterDelimited(longVal);

                return String.join(".", eightCharacterDelimitedList);
        }

        /**
         * ipAddress -> long
         * @param ipAddress IpAddress （文字列）
         * @return 2進数 IpAddress （long）
         */
        private static long ipAddress2Long(String ipAddress){
                String[] split = ipAddress.split(Pattern.quote("."));
                String binary = Arrays.stream(split)
                        .map(Integer::parseInt)
                        .map(Integer::toBinaryString)
                        .map(x -> zeroPadded(x,8))
                        .collect(Collectors.joining());
                return Long.parseLong(binary, 2);
        }

        /**
         * val を maxLength まで先頭0埋めする
         * @param val 文字列
         * @param maxLength 最大長
         * @return 0埋めされた文字列
         */
        private static String zeroPadded(String val, int maxLength){
                StringBuilder result = new StringBuilder();
                for (int i = val.length(); i < maxLength; i++){
                        result.append("0");
                }
                result.append(val);
                return result.toString();
        }

        /**
         * val を8文字区切りにして Listで 返す
         * @param val 文字列
         * @return 8文字区切りにした List
         */
        private static List<String> eightCharacterDelimited(String val){
                Matcher m = Pattern.compile("[\\s\\S]{1,8}").matcher(val);
                List<String> separatedList = new ArrayList<>();
                while (m.find()) {
                        String group = m.group();
                        separatedList.add(group);
                }
                return separatedList;
        }
}


```


Javaで文字列がネットワークを表すCIDR形式として正しいか判定する


## TL;DR

* Javaコンパイラの encoding 設定とは別に、 AspectJコンパイラの encoding 設定も必要だった
* 文字化けせずにログが出るように検証したンプルは↓
    - https://github.com/o-hayato/AspectJ-sample

## 発生状況

* Java + AspectJ の検証をするために [gradle-aspectj](https://github.com/eveoh/gradle-aspectj) プラグインを使って検証していた
* AspectJ で出している部分のログは文字化けするが、コードから直接出しているログは文字化けしないという謎の現象が発生した

## 原因

* Javaコンパイラの encoding 設定 は `UTF-8` として設定していた
* encoding の設定をして安心していたが、 AspectJコンパイラの encoding 設定は別途必要だった

## 対処法

```
compileAspect {
    additionalAjcArgs = ['encoding' : 'UTF-8']
}

compileTestAspect {
    additionalAjcArgs = ['encoding' : 'UTF-8']
}
```

compileAspect と compileTestAspect に encoding の設定を追加する

## 参考

* https://github.com/eveoh/gradle-aspectj
* http://www.eclipse.org/aspectj/doc/released/devguide/antTasks-iajc.html#antTasks-iajc-options


Java + AspectJ + Gradle でログが文字化けするのを解決した


[SonarQubeの最新版プラグイン](http://docs.sonarqube.org/display/SONAR/Analyzing+with+SonarQube+Scanner+for+Gradle)の使い方に関する日本語情報が少なかったから書いてみました。

# 追記(20170124)

```
        property "sonar.jdbc.url", "jdbc:h2:tcp://192.168.0.1:9092/sonar"
        property "sonar.jdbc.username", "sonar"
        property "sonar.jdbc.password", "sonar"
```

の部分は最新版のSonerQubeでは設定不要になったので注意

# 事前準備

[SonarQubeでプログラムの品質管理をはじめる（インストール）](http://qiita.com/sh-ogawa/items/4966afaaed72b444ab80)
を確認してSonarQubeのインストールが終わっている事

# build.gradle の 設定変更

```
buildscript {
    repositories { 
      maven {
        url "http://repo1.maven.org/maven2/"
      }
      maven {
        url "https://plugins.gradle.org/m2/"
      }
      mavenLocal()
    }
    dependencies { 
      classpath 'org.sonarqube.gradle:gradle-sonarqube-plugin:1.0'
    }
}

apply plugin: 'java'
apply plugin: 'org.sonarqube'
apply plugin: 'jacoco'

sonarqube {
    properties {
        property "sonar.host.url", "http://192.168.0.1/"
        property "sonar.jdbc.url", "jdbc:h2:tcp://192.168.0.1:9092/sonar"
        property "sonar.jdbc.driverClassName", "com.mysql.jdbc.Driver"
        property "sonar.jdbc.username", "sonar"
        property "sonar.jdbc.password", "sonar"
        property "sonar.jacoco.reportPath", "${project.buildDir}/jacoco/test.exec"
    }
}

```


### 注意点1

`sonar.host.url`、`sonar.jdbc.url`、`sonar.jdbc.username`、`sonar.jdbc.password`には[SonarQubeでプログラムの品質管理をはじめる（インストール）](http://qiita.com/sh-ogawa/items/4966afaaed72b444ab80)で sonar.properties に設定した値を入れる事。
その設定を間違うと、`Cannot load JDBC driver class 'com.mysql.jdbc.Driver'`が発生して失敗するので注意すること

### 注意点2

`apply plugin: 'jacoco'` と `sonar.jacoco.reportPath` の設定をしないとカバレッジが表示されない。
カバレッジが表示されない場合はここを疑うこと。

# 参考

* [SonarSource/sonar-examples](https://github.com/SonarSource/sonar-examples/blob/master/projects/multi-module/gradle/java-gradle-modules/build.gradle)


Gradle から SonarQube を利用する方法


## TL;DR

`@Id` が付いているパラメタにDB上で auto_increment が設定されている場合、  
そのパラメタにコード上で値を入れて persist() すると一意制約例外が発生する。

回避するためには persist() の代わりに merge() を使う。

## 解説

### 発生状況

persistence.xml に以下が設定されている

```xml
<property name="eclipselink.validate-existence" value="true"/>
```

コード上で `@Entity` のオブジェクトを new した後、全てのパラメタに値を詰めて persist() したところ

```java
javax.persistence.EntityExistsException: Exception Description: Cannot persist detached object
```

が発生した。

DB上では、該当オブジェクトの `@Id` が付いているパラメタに auto_increment が設定されていた。

### 原因

http://www.eclipse.org/eclipselink/documentation/2.5/jpa/extensions/p_validate_existence.htm  
を見ると persistence context に存在しない場合にエラーが発生すると書いてあることから調査を開始してみた。

JPAで処理される際に、 auto_increment のカラムに @Id が付与されている場合  
`GeneratedValue strategy=GenerationType.SEQUENCE` と判断される
(@Id指定だけの時はDBみて自動判断？ http://otndnld.oracle.co.jp/products/ias/toplink/jpa/resources/toplink-jpa-annotations.html#Id )

オブジェクトを persist() した際に  
`GeneratedValue strategy=GenerationType.SEQUENCE` なのに `@Id` のパラメタに値が入っている  
かつ PersistenceContext に入ってない → 分離状態(detached object)と判定  
detached object なのに persist しようとしている  
 → `javax.persistence.EntityExistsException: Exception Description: Cannot persist detached object`

という流れでエラーになっている

### 対処方法

* `@Id` 指定されているパラメタに値が入っている場合は、persist() の代わりに merge() を使う
    - 参考 → http://stackoverflow.com/questions/10463460/cannot-persist-detached-object

## 参考

* http://kokuzawa.github.io/blog/2014/01/31/entityexistsexception/
* http://www.eclipse.org/eclipselink/documentation/2.5/jpa/extensions/p_validate_existence.htm
* http://stackoverflow.com/questions/10463460/cannot-persist-detached-object
* http://otndnld.oracle.co.jp/products/ias/toplink/jpa/resources/toplink-jpa-annotations.html#Id
* http://otndnld.oracle.co.jp/products/ias/toplink/jpa/resources/toplink-jpa-annotations.html#GeneratedValue
* http://etc9.hatenablog.com/entry/20090830/1251606823


EclipseLinkでDBに存在しないレコードに対しての一意制約例外が発生する


# 発生原因

streamの中などでラムダ式のメソッドリファレンスを使いprivateメソッドなどを呼んでいると発生する。
本来発生する必要のない指摘。

# 解消方法

1. SonarQubeのJavaプラグインを**3.14**以上にアップデートする

# 参考

* https://jira.sonarsource.com/browse/SONARJAVA-583
* https://jira.sonarsource.com/browse/SONARJAVA/fixforversion/13031/?selectedTab=com.atlassian.jira.plugins.jira-development-integration-plugin:release-report-tabpanel

ラムダ式のメソッドリファレンスを使った特に squid : UnusedPrivateMethod が発生した時の対処方法


# 発生原因

可読性が低くなるから検査例外をthrowしてはいけないと指摘されている  
発生させている例外が本当に検査例外でなければいけないかを考えてから以下の対応を取る

# 解消方法

1. 検査例外を明示的に投げるようなインターフェイスを作成する
2. そのクラスの実装として検査例外を投げるクラスを作成する

※ SonarQubeのJavaプラグインが 3.10 より低いと、この対処を行っても発生する

# Tips

スーパークラスやインターフェイスで強制されていないのに  
検査例外を非検査例外に変換すると別のチェックに引っかかる
* http://fb-contrib.sourceforge.net/bugdescriptions.html
    - `EXS_EXCEPTION_SOFTENING_NO_CONSTRAINTS`


# 参考

* https://jira.sonarsource.com/browse/SONARJAVA-1498

SonarQube で squid:S1162 が発生した時の対処方法


## TL;DR

@Id が付いているパラメタにDB上で auto_increment が設定されている場合、  
そのパラメタにコード上で値を入れて persist() すると一意制約例外が発生する。

回避するためには persist() の代わりに merge() を使う。

## 解説

### 発生状況

persistence.xml に以下が設定されている

```xml
<property name="eclipselink.validate-existence" value="true"/>
```

コード上で @Entity のオブジェクトを new した後、全てのパラメタに値を詰めて persist() したところ

```java
javax.persistence.EntityExistsException: Exception Description: Cannot persist detached object
```

が発生した。

DB上では、該当オブジェクトの @Id が付いているパラメタに auto_increment が設定されていた。

### 原因

http://www.eclipse.org/eclipselink/documentation/2.5/jpa/extensions/p_validate_existence.htm  
を見ると persistence context に存在しない場合にエラーが発生すると書いてあることから調査を開始してみた。

JPAで処理される際に、 auto_increment のカラムに @Id が付与されている場合  
`GeneratedValue strategy=GenerationType.SEQUENCE` と判断される
(@Id指定だけの時はDBみて自動判断？ http://otndnld.oracle.co.jp/products/ias/toplink/jpa/resources/toplink-jpa-annotations.html#Id )

オブジェクトを persist() した際に  
`GeneratedValue strategy=GenerationType.SEQUENCE` なのに @Id のパラメタに値が入っている  
かつ PersistenceContext に入ってない → 分離状態(detached object)と判定  
detached object なのに persist しようとしている  
 → `javax.persistence.EntityExistsException: Exception Description: Cannot persist detached object`

という流れでエラーになっている

### 対処方法

* @Id 指定されているパラメタに値が入っている場合は、persist() の代わりに merge() を使う
    - 参考 → http://stackoverflow.com/questions/10463460/cannot-persist-detached-object

## 参考

* http://kokuzawa.github.io/blog/2014/01/31/entityexistsexception/
* http://www.eclipse.org/eclipselink/documentation/2.5/jpa/extensions/p_validate_existence.htm
* http://stackoverflow.com/questions/10463460/cannot-persist-detached-object
* http://otndnld.oracle.co.jp/products/ias/toplink/jpa/resources/toplink-jpa-annotations.html#Id
* http://otndnld.oracle.co.jp/products/ias/toplink/jpa/resources/toplink-jpa-annotations.html#GeneratedValue
* http://etc9.hatenablog.com/entry/20090830/1251606823

SonarQube で squid:S1162 が発生した時の対処方法

# エラー本文

```
Checked Exception should not be thrown
squid:S1162

    error-handling, security Maintainability > Understandability 

The purpose of checked exceptions is to ensure that errors will be dealt with, either by propagating them or by handling them,
but some believe that checked exceptions negatively impact the readability of source code,
by spreading this error handling/propagation logic everywhere.

This rule verifies that no method throws a new checked exception.
```

# 発生原因

可読性が低くなるから検査例外をthrowしてはいけないと指摘されている  
発生させている例外が本当に検査例外でなければいけないかを考えてから以下の対応を取る

# 解消方法

1. 検査例外を明示的に投げるようなインターフェイスを作成する
2. そのクラスの実装として検査例外を投げるクラスを作成する

:warning: SonarQubeのJavaプラグインが 3.10 より低いと、この対処を行っても発生する :warning:

# Tips

スーパークラスやインターフェイスで強制されていないのに
検査例外を非検査例外に変換すると別のチェックに引っかかる

* http://fb-contrib.sourceforge.net/bugdescriptions.html
    - `EXS_EXCEPTION_SOFTENING_NO_CONSTRAINTS`


# 参考

* https://jira.sonarsource.com/browse/SONARJAVA-1498



# AkkaのActorをテストする（Java編）

AkkaのActorをテストした時のメモ。
メモなので間違ってたら指摘いただけるとありがたいです。

## 事前準備

### テストで使用するサンプルActor

```java
static class MyActor extends UntypedActor {
  public void onReceive(Object o) throws Exception {
    if (o.equals("say42")) {
      getSender().tell(42, getSelf());
    } else if (o instanceof Exception) {
      throw (Exception) o;
    }
  }
  public boolean testMe() { return true; }
}
```

## TIPS

### 適当なActorを作りたい

```java
@Test
public void testActor() {
    new JavaTestKit(system) {{
        final TestProbe worker = new TestProbe(system);
        ActorRef workerActorRef = worker.ref(); // ActorRefを取得できる
    }};
}
```

ActorRefを引数に取るメソッドや、ActorRefをメッセージとしてやり取りする時に使う

## Actorインスタンス内のメソッドをテストする

```java
@Test
public void demonstrateTestActorRef() {
  final Props props = Props.create(MyActor.class);
  final TestActorRef<MyActor> ref = TestActorRef.create(system, props, "testA");
  final MyActor actor = ref.underlyingActor(); // Actorインスタンスの取得
  assertTrue(actor.testMe());
}
```

通常ActorRefからはActorのインスタンスを取得することはできないが、
TestActorRefをつかうとActorのインスタンスを取得出来るようになる。
取得したインスタンスでメソッドを実行することで単体テストする

### メッセージ受信のテスト
```java
@Test
public void testActorRef() {
        new JavaTestKit(system) {{
            final TestProbe aggregator = new TestProbe(system);

            String message = "test message";
            aggregator.ref().tell(message, getRef());
            aggregator.expectMsg(message);
            assertEquals(getRef(), aggregator.lastSender());
        }};
}
```

TestProbeを使って適当なActorを作る。
ActorRefを取得してメッセージを送信して、expectMsgでメッセージが受信されたことのテストをする。
lastSender()でどこからメッセージが来たかもテスト出来る


## Actor停止挙動のテスト

```java
@Test
public void testActorRef() {
    new JavaTestKit(system) {{
      final Props props = Props.create(MyActor.class);
      final TestActorRef<MyActor> target = TestActorRef.create(system, props, "testA");

      final JavaTestKit probe = new JavaTestKit(system);
      probe.watch(target);
      target.tell(PoisonPill.getInstance(), ActorRef.noSender());
      final Terminated msg = probe.expectMsgClass(Terminated.class);
      assertEquals(msg.getActor(), target);
    }};
}
```

targetをJavaTestKitで監視しておいて、PoisonPillを送る。
そのあと、Terminatedメッセージを受信することを確認する
応用すれば、他のアクターを殺すようなReaperのテストでも使えそう。



## 参考
* http://doc.akka.io/docs/akka/2.4.0/java/testing.html#Built-In_Assertions
* http://qiita.com/reoring/items/3baeac37ba0d63f39693


AkkaのActorをテストする（Java編）


http://letitcrash.com/post/30165507578/shutdown-patterns-in-akka-2  
を読んでのメモ
☆が付いてるのは所感
それ以外は記事の適当に訳してまとめたもの

# Shutdown Patterns in Akka 2

「すべての処理が終了したらActorSystemをシャットダウンするにはAkkaにどう命令したらいい？」

以下を議論する

* 「適切なタイミング」でシャットダウンするための簡単な方法
* 同じことをやるためのそれほど簡単ではない方法

## What the Heck Does “Finished” Mean?

* まず “Finished” をどう定義するか
* 「メールボックスが空になった時」（正確に言えば間違ってるけど）
    - まだメッセージを送信してないアクターがいる可能性があるから
    - 図のようにメースボックスの中身を全部飲み込んで処理中のやつがいたりするしね
* 一気のみするアクターが数百発生する確率は低い
    - ただ確率が上がるごとにそのアプリは終わりに近づくけどね
    - それが0.004%だったとしてもアルゴリズムをデザインするプラットフォームとしては疑わしい
* 「アクターが機能しているか知ることができるので、メールボックスがからじゃない時と機能しているときは停止しないで！」
    - そうはいうけどこういう時↓は停止したくないでしょ？
        + もしアクターが未来の作業を生成していたら？
        + 別のマシンの要求を待っていたら？
    - 逆にアプリを動作実態とは逆に"ビジー"に保つ単純な何かがいるとしたら永遠にアプリを実行し続ける？
        + ふつうやらないよね

## The DABOWoTeD Pattern（Do A Bunch Of Work Then Die pattern）

* 「房ごとに死んでいくパータン」
    - ☆DABOWoTeDの発音になんか意味があるらしいけど分からなかった
* 24/365で動いてるアプリはシャットダウン時の動きをそんなに気にしてないんじゃない
    - ハードウェア障害に対応するほうが頻繁だと思うし
* 仕事をさせるために幾つかのアクターを房にする
    - その仕事が「完了」している時がシャットダウンするとき

### Futures

* Futures はすべてが完了したのを知る簡単な方法
    - シーケンシャルに処理できる
* 基本的に大きなfork-joinをやってるだけ
    - すべてがjoin upした時にそのシステムをシャットダウンする

### Acotr

* “Finished”が明確じゃない
    - アルゴリズムにアクターが高いレベルで入り込んでいるから

### The Reaper

* 死神
    - アクターの死を監視するアクター
    - 監視しているアクター（図では緑）がすべて死んだ時システムを終了させる
    - 死んだアクターの通知をすべて集めた時、死神がシステムを終了に向かわせる


### Reaper Code

* Reaper自体は簡単、ActorRefを監視してそれらが死んだ時にキックするメソッドを作るだけ

### A “Production” Reaper

* 死神の簡単さから考えて、Production Reaperを作ることができる
    - すべての魂を集め終わったらActorSystemをシャットダウンするような

### Testing the Reaper

* Akka の テストキットを使ってReaperをテストする



## Application with PoisonPill

* Reaper はとても柔軟
    - あるゴールがメールボックスから排出される場合
* メッセージの束をアクターに送り、他のアクターにもメッセージが送られるシステムが有るとする
    - メールボックスからあるキーが排出された時にシャットダウンしたい
        + そういう時は PoisonPill メッセージを利用する
        + PoisonPill はActorのメールボックスに入り、やがてActorを殺す
            * 重要なのはPoisonPillより前に受け取ったメッセージはすべて処理されるということ
            * system.stpoを使ってActorを殺した場合にはそうならない
    - 最後のPoisonPillが処理されるとReaperがキックされActorSystemがシャットダウンされる
* ☆PoisonPillを受け取ったら自殺するようにActorを作ればいいのか

## Conclusion

* Akkaはあなたが何をやってるか知らない
    - しってるのはあなた自身だけ
* Reaperパターンはシステムに抽象レベルを設定するために使用された
    - Actorの基本的な機能を使用してアプリケーションに「システムレベル」の振る舞いを追加するための



Java

Gradle を使って jCenter に java ライブラリを公開する

Javaで文字列がネットワークを表すCIDR形式として正しいか判定する

Java + AspectJ + Gradle でログが文字化けするのを解決した

Gradle から SonarQube を利用する方法

EclipseLinkでDBに存在しないレコードに対しての一意制約例外が発生する

ラムダ式のメソッドリファレンスを使った特に squid : UnusedPrivateMethod が発生した時の対処方法

SonarQube で squid:S1162 が発生した時の対処方法

EclipseLinkでDBに存在しないレコードに対しての一意制約例外が発生する

SonarQube で squid:S1162 が発生した時の対処方法

AkkaのActorをテストする（Java編）

Shutdown Patterns in Akka 2 を読んでのメモ