assertNotNull( this.event ) ;
    public void testDefaultDecoderManager() throws Exception    {        AbandonRequest request = new AbandonRequestImpl( 6 ) ;        request.setAbandoned( 44 ) ;        MessageEncoder encoder = new MessageEncoder() ;                byte [] encoded = encoder.encode( request ) ;        ByteBuffer buf = bp.getBuffer( this ) ;        buf.put( encoded ) ;        buf.flip() ;                final BufferPool pool = bp ;        InputEvent e = new InputEvent( this, null, buf )         {            public ByteBuffer claimInterest(Object party)            {                pool.claimInterest(getBuffer(), party) ;                return getBuffer().asReadOnlyBuffer() ;            }            public void releaseInterest(Object party)            {                pool.releaseClaim(getBuffer(), party) ;            }        } ;                bp.releaseClaim(buf, this) ;        router.publish( new ConnectEvent(this, null) ) ;        router.publish( e ) ;        decodeMan.stop() ;        assertNotNull( this.event ) ;    }