+ @Override
+ @SuppressWarnings("checkstyle:IllegalCatch")
+ public Optional<Cluster> getCluster() {
+ if (cluster == null) {
+ try {
+ cluster = Optional.of(Cluster.get(getActorSystem()));
+ } catch (Exception e) {
+ // An exception means there's no cluster configured. This will only happen in unit tests.
+ log.debug("{}: Could not obtain Cluster: {}", getId(), e);
+ cluster = Optional.empty();
+ }
+ }
+
+ return cluster;
+ }
+