public void init ( String txn , TransactionConfig btc ) { if ( log . isLoggable ( Level . FINE ) ) { log . fine ( "ProcessManager: initialise btxn '" + txn + "' config=" + btc + " processors=" + btc . getProcessors ( ) . size ( ) ) ; } if ( btc . getProcessors ( ) != null && ! btc . getProcessors ( ) . isEmpty ( ) ) { List < ProcessorWrapper > procs = new ArrayList < ProcessorWrapper > ( ) ; for ( int i = 0 ; i < btc . getProcessors ( ) . size ( ) ; i ++ ) { procs . add ( new ProcessorWrapper ( btc . getProcessors ( ) . get ( i ) ) ) ; } synchronized ( processors ) { processors . put ( txn , procs ) ; } } else { synchronized ( processors ) { processors . remove ( txn ) ; } } }
This method initialises the processors associated with the supplied transaction configuration .