getInstance() instanceof ClusteredDOMDataTreeChangeListener),
actorUtils.getDatastoreContext().getShardInitializationTimeout());
- future.onComplete(new OnComplete<Object>() {
+ future.onComplete(new OnComplete<>() {
@Override
public void onComplete(final Throwable failure, final Object result) {
if (failure != null) {