private boolean readSend ( InH3 hIn , OutboxAmp outbox , HeadersAmp headers ) throws IOException { MethodRefHamp methodHamp = null ; try { methodHamp = readMethod ( hIn ) ; } catch ( Throwable e ) { log . log ( Level . FINER , e . toString ( ) , e ) ; skipArgs ( hIn ) ; return true ; } MethodRefAmp method = methodHamp . getMethod ( ) ; //ClassLoader loader = method.getService().getManager().getClassLoader(); ClassLoader loader = methodHamp . getClassLoader ( ) ; Thread thread = Thread . currentThread ( ) ; thread . setContextClassLoader ( loader ) ; // XXX: _serializer.setClassLoader(loader); Object [ ] args = readArgs ( methodHamp , hIn ) ; if ( log . isLoggable ( _logLevel ) ) { log . log ( _logLevel , this + " send-r " + method . getName ( ) + debugArgs ( args ) + " {to:" + method + ", " + headers + "}" ) ; } // XXX: s/b systemMailbox SendMessage_N sendMessage = new SendMessage_N ( outbox , headers , method . serviceRef ( ) , method . method ( ) , args ) ; long timeout = 1000L ; // mailbox delay timeout try { //sendMessage.offer(timeout); //sendMessage.offerQueue(timeout); // // sendMessage.getWorker().wake(); sendMessage . offer ( timeout ) ; } catch ( Throwable e ) { log . fine ( e . toString ( ) ) ; if ( log . isLoggable ( Level . FINEST ) ) { log . log ( Level . FINEST , e . toString ( ) , e ) ; } } return true ; }
The send message is a on - way call to a service .