public void rollback ( ) { // Remove incomplete message from the outbound pipe. Msg msg ; if ( outpipe != null ) { while ( ( msg = outpipe . unwrite ( ) ) != null ) { assert ( msg . hasMore ( ) ) ; } } }
Remove unfinished parts of the outbound message from the pipe .