//
//
+ @Override
+ protected void haltClient(final Throwable cause) {
+ // FIXME: Add state flushing here once we have state
+ }
+
private void createLocalHistory(final CreateLocalHistoryCommand command) {
final CompletableFuture<ClientLocalHistory> future = command.future();
final LocalHistoryIdentifier historyId = new LocalHistoryIdentifier(getIdentifier(), nextHistoryId++);
} else if (command instanceof GetClientRequest) {
((GetClientRequest) command).getReplyTo().tell(new Status.Success(this), ActorRef.noSender());
} else if (SHUTDOWN.equals(command)) {
- // Add shutdown procedures here
+ // FIXME: Add shutdown procedures here
return null;
} else {
LOG.warn("{}: ignoring unhandled command {}", persistenceId(), command);