- public void onReceiveRecover(Object message) throws Exception {
- final String messageType = message.getClass().getSimpleName();
- LOG.trace("Received message {}", messageType);
- handleRecover(message);
- LOG.trace("Done handling message {}", messageType);
+ public final Receive createReceiveRecover() {
+ return receiveBuilder().matchAny(this::handleRecover).build();