- @Override public void onReceive(Object message) throws Exception {
- final String messageType = message.getClass().getSimpleName();
- if(LOG.isDebugEnabled()) {
- LOG.debug("Received message {}", messageType);
- }
- handleReceive(message);
- if(LOG.isDebugEnabled()) {
- LOG.debug("Done handling message {}", messageType);
+ @Override
+ public final void onReceive(final Object message) throws Exception {
+ if (message instanceof ExecuteInSelfMessage) {
+ ((ExecuteInSelfMessage) message).run();
+ } else {
+ handleReceive(message);