public void sendSharedObjectMessage ( String name , int currentVersion , boolean persistent , Set < ISharedObjectEvent > events ) { // create a new sync message for every client to avoid concurrent access through multiple threads SharedObjectMessage syncMessage = state . getEncoding ( ) == Encoding . AMF3 ? new FlexSharedObjectMessage ( null , name , currentVersion , persistent ) : new SharedObjectMessage ( null , name , currentVersion , persistent ) ; syncMessage . addEvents ( events ) ; try { // get the channel for so updates Channel channel = getChannel ( 3 ) ; if ( log . isTraceEnabled ( ) ) { log . trace ( "Send to channel: {}" , channel ) ; } channel . write ( syncMessage ) ; } catch ( Exception e ) { log . warn ( "Exception sending shared object" , e ) ; } }
Send a shared object message .