@ SuppressWarnings ( "checkstyle:illegalcatch" ) private void deliverMessageToTask ( final byte [ ] message ) throws TaskMessageHandlerFailure { try { this . fMessageHandler . get ( ) . onNext ( new DriverMessageImpl ( message ) ) ; } catch ( final Throwable throwable ) { throw new TaskMessageHandlerFailure ( throwable ) ; } }
Calls the configured Task message handler and catches exceptions it may throw .