public void deserialize ( final BinaryDecoder decoder , final MultiObserver observer , final long sequence ) throws IOException , IllegalAccessException , InvocationTargetException { final TMessage message = messageReader . read ( null , decoder ) ; if ( message != null ) { observer . onNext ( sequence , message ) ; } else { throw new RuntimeException ( "Failed to deserialize message [" + msgMetaClass . getSimpleName ( ) + "]" ) ; } }
Deserialize messages of type TMessage from input decoder .