- public final void onReceiveCommand(final Object message) throws Exception {
- final String messageType = message.getClass().getSimpleName();
- LOG.trace("Received message {}", messageType);
-
- if (message instanceof ExecuteInSelfMessage) {
- LOG.trace("Executing {}", message);
- ((ExecuteInSelfMessage) message).run();
- } else {
- handleCommand(message);
- }
-
- LOG.trace("Done handling message {}", messageType);
+ public final Receive createReceive() {
+ return receiveBuilder()
+ .match(ExecuteInSelfMessage.class, ExecuteInSelfMessage::run)
+ .matchAny(this::handleCommand)
+ .build();